Package com.avoka.fc.core.service

Class EventInboxService

java.lang.Object

com.avoka.fc.core.service.BaseService

com.avoka.fc.core.service.CayenneService

com.avoka.fc.core.service.EventInboxService

public class EventInboxService
extends CayenneService

Provides an event inbox service which handles event inbox entity creation and updating.

Since:

24.4.0

Constructor Summary

Constructors

Constructor	Description
EventInboxService()

Method Summary

Modifier and Type	Method	Description
EventInbox	createInboxEvent(ServiceDefinition serviceDefinition, String eventTopic, String eventPartition, String eventOffset, String key, String payload)	create a new EventInbox entity.
void	updateEventInboxToDelivered(EventInbox eventInbox)	update an eventInbox with delivered status.
void	updateEventInboxToFailed(EventInbox eventInbox, String bodyContent)	update an eventInbox with Failed status.
void	updateEventInboxToFailed(Long eventId, String bodyContent)	update an eventInbox with Failed status.
void	updateEventInboxToInProcess(EventInbox eventInbox)	update an eventInbox with InProcess status.
void	updateEventInboxToInQueue(EventInbox eventInbox)	update an eventInbox with InQueue status.

Methods inherited from class com.avoka.fc.core.service.CayenneService

commitChanges, deleteObject, deleteObjects, findObject, getDataContext, getDataDomain, getObjectForPK, getObjectStore, newObject, performNamedQuery, performNamedQuery, performNamedQuery, performNonSelectingQuery, performNonSelectingQuery, performNonSelectingQuery, performNonSelectingQuery, performQuery, performQuery, refetchEntity, refetchObject, registerNewObject, rollbackChanges, toMap, toMap

Methods inherited from class com.avoka.fc.core.service.BaseService

getLogger

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

EventInboxService

public EventInboxService()

Method Details

createInboxEvent

public EventInbox createInboxEvent(ServiceDefinition serviceDefinition,
 String eventTopic,
 String eventPartition,
 String eventOffset,
 String key,
 String payload)

create a new EventInbox entity.

Parameters:

serviceDefinition - the serviceDefinition (required)

eventTopic - the event Topic (required)

eventPartition - the event Partition

eventOffset - the event Offset (required)

key - the key

payload - the payload (required)

Returns:

the created EventInbox entity

updateEventInboxToDelivered

public void updateEventInboxToDelivered(EventInbox eventInbox)

update an eventInbox with delivered status.

Parameters:

eventInbox - the eventInbox

updateEventInboxToFailed

public void updateEventInboxToFailed(EventInbox eventInbox,
 String bodyContent)

update an eventInbox with Failed status.

Parameters:

eventInbox - the eventInbox

bodyContent - The body content

updateEventInboxToFailed

public void updateEventInboxToFailed(Long eventId,
 String bodyContent)

update an eventInbox with Failed status.

Parameters:

eventId - the eventInbox id

bodyContent - The body content

updateEventInboxToInQueue

public void updateEventInboxToInQueue(EventInbox eventInbox)

update an eventInbox with InQueue status.

Parameters:

eventInbox - the eventInbox

updateEventInboxToInProcess

public void updateEventInboxToInProcess(EventInbox eventInbox)

update an eventInbox with InProcess status.

Parameters:

eventInbox - the eventInbox