Package com.avoka.fc.core.dao
Class SubmissionAsyncMsgDao
- java.lang.Object
-
- com.avoka.core.dao.BaseDao
-
- com.avoka.fc.core.dao.AbstractDao
-
- com.avoka.fc.core.dao.SubmissionAsyncMsgDao
-
public class SubmissionAsyncMsgDao extends AbstractDao
Provides a DAO for the SubmissionAsyncMsg entity.- Since:
- 4.3.2
- See Also:
SubmissionAsyncMsg
-
-
Field Summary
-
Fields inherited from class com.avoka.core.dao.BaseDao
FETCH_LIMIT, STATEMENT_MAX_NO_PARAMETERS
-
-
Constructor Summary
Constructors Constructor Description SubmissionAsyncMsgDao()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SubmissionAsyncMsg
getAsyncMsgForID(Object id)
Return the submission async message for the given primary key.SubmissionAsyncMsg
getAsyncMsgForKey(String msgKey)
Return the submission async message for the given msg key.List<SubmissionAsyncMsg>
getReadyAsyncMsgsForExpiry()
Return list of 'Ready' status async messages which have expiredList<SubmissionAsyncMsg>
getReadyAsyncMsgsForTopic(String topic, int fetchLimit)
Return list of 'Ready' status async messages for given topic.-
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
-
-
-
-
Method Detail
-
getAsyncMsgForID
public SubmissionAsyncMsg getAsyncMsgForID(Object id)
Return the submission async message for the given primary key.- Parameters:
id
- the OID- Returns:
- the submission async message for the given primary key, or null if not found or access is not authorized
-
getAsyncMsgForKey
public SubmissionAsyncMsg getAsyncMsgForKey(String msgKey)
Return the submission async message for the given msg key.- Parameters:
msgKey
- the message key- Returns:
- the submission async message for the given primary key, or null if not found or access is not authorized
-
getReadyAsyncMsgsForTopic
public List<SubmissionAsyncMsg> getReadyAsyncMsgsForTopic(String topic, int fetchLimit)
Return list of 'Ready' status async messages for given topic.- Parameters:
topic
- the messages topicfetchLimit
- the request fetch limit- Returns:
- list of 'Ready' status async messages for given topic
-
getReadyAsyncMsgsForExpiry
public List<SubmissionAsyncMsg> getReadyAsyncMsgsForExpiry()
Return list of 'Ready' status async messages which have expired- Returns:
- list of 'Ready' status async messages which have expired
-
-