Package com.avoka.fc.core.outbox

Interface IOutboxProcessor

All Known Implementing Classes:

MockOutboxProcessor, OutboxProcessor

public interface IOutboxProcessor

Provide an outbox processor interface.

Since:

22.10.0

Method Summary

Modifier and Type	Method	Description
IStreamProducer	createProducer(ServiceConnection serviceConnection)	create a producer to produce message with it.
void	processOutboxEvent(Long eventId)	Process the event.
EventOutbox	raiseEvent(ServiceConnection serviceConnection, String eventTopic, String payload, String eventDetails, String entityType, String entityId, UserAccount user)	Create a new EventOutbox entity.
void	sendOutboxEventsToProcess()	gets events from storage and send them to process.

Method Details

createProducer

IStreamProducer createProducer(ServiceConnection serviceConnection)

create a producer to produce message with it.

Parameters:

serviceConnection - the serviceConnection

Returns:

an instance of IStreamProducer

raiseEvent

EventOutbox raiseEvent(ServiceConnection serviceConnection,
 String eventTopic,
 String payload,
 String eventDetails,
 String entityType,
 String entityId,
 UserAccount user)

Create a new EventOutbox entity.

Parameters:

serviceConnection - the serviceConnection for sending event

eventTopic - the topic which event should be sent to

payload - the payload which should be sent

eventDetails - the event details

entityType - the entity type related to this event

entityId - the entity ID related to this event

user - the user login name

Returns:

the created EventOutbox entity

sendOutboxEventsToProcess

void sendOutboxEventsToProcess()

gets events from storage and send them to process.

processOutboxEvent

void processOutboxEvent(Long eventId)

Process the event.

Parameters:

eventId - and eventId