Package com.avoka.fc.core.dao

Class EventOutboxDao

java.lang.Object

com.avoka.core.dao.BaseDao

com.avoka.fc.core.dao.AbstractDao

com.avoka.fc.core.dao.EventOutboxDao

public class EventOutboxDao
extends AbstractDao

Provides a DAO for the EventOutbox entity.

Since:

22.10.0

Field Summary

Fields inherited from class com.avoka.core.dao.BaseDao

FETCH_LIMIT, STATEMENT_MAX_NO_PARAMETERS

Constructor Summary

Constructors

Constructor	Description
EventOutboxDao()

Method Summary

Modifier and Type	Method	Description
List<EventOutbox>	getEventListForProcessing(int fetchLimit, int queueTimeout, int inProgressTimeout, int maxRetry)	Return the list of EventOutbox entities which needs to be processed
EventOutbox	getEventOutboxForId(Long id)	Return the EventOutbox entity for the given EventOutbox id.

Methods inherited from class com.avoka.fc.core.dao.AbstractDao

andFilterClientExcludeNull, andFilterClientIncludeNull, andFilterClientOnly, isClientAccessAllowed, performQueryConfigCached

Methods inherited from class com.avoka.core.dao.BaseDao

addOrdering, addOrderingCaseInsensitive, addOrderingCaseSensitive, andQueryBetween, andQueryInExp, andQueryInExp, andQueryLikeIgnoreCaseExp, andQueryMatchDbExp, andQueryMatchExp, andQueryMatchIsNotNull, andQueryMatchIsNull, andQueryNoMatchExp, andQueryNotTrue, deleteObject, deleteObjects, findObject, getDataContext, getFetchLimit, getLogger, getObjectForPK, newObject, orQueryLikeIgnoreCaseExp, orQueryMatchExp, performNamedQuery, performNamedQuery, performNamedQuery, performNamedQuery, performNonSelectingQuery, performNonSelectingQuery, performNonSelectingQuery, performNonSelectingQuery, performQuery, performQuery, performQuery, registerNewObject, setCacheStrategy, setFetchLimit, setLocalCacheStrategy, setLocalCacheStrategy, setSharedCacheStrategy, toMap, toMap

Methods inherited from class java.lang.Object

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

Constructor Details

EventOutboxDao

public EventOutboxDao()

Method Details

getEventOutboxForId

public EventOutbox getEventOutboxForId(Long id)

Return the EventOutbox entity for the given EventOutbox id.

Parameters:

id - the EventOutbox id (required)

Returns:

the EventOutbox entity for the given EventOutbox id

getEventListForProcessing

public List<EventOutbox> getEventListForProcessing(int fetchLimit,
 int queueTimeout,
 int inProgressTimeout,
 int maxRetry)

Return the list of EventOutbox entities which needs to be processed

Parameters:

fetchLimit - the maximum limit to limit the number of result objects.

queueTimeout - the maximum time we expect an outbox event to be in Blocking Queue(in milliseconds).

inProgressTimeout - the maximum time we expect an outbox event to be in progress status (waiting for process to be completed)(in milliseconds).

maxRetry - the maxRetry to send outbox events

Returns:

the list of EventOutbox entities