|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.springframework.integration.store.AbstractMessageGroupStore
public abstract class AbstractMessageGroupStore
Field Summary | |
---|---|
protected org.apache.commons.logging.Log |
logger
|
Constructor Summary | |
---|---|
AbstractMessageGroupStore()
|
Method Summary | |
---|---|
int |
expireMessageGroups(long timeout)
Extract all expired groups (whose timestamp is older than the current time less the threshold provided) and call each of the registered callbacks on them in turn. |
int |
getMessageCountForAllMessageGroups()
Optional attribute giving the number of messages in the store over all groups. |
int |
getMessageGroupCount()
Optional attribute giving the number of message groups. |
boolean |
isTimeoutOnIdle()
|
void |
registerMessageGroupExpiryCallback(MessageGroupCallback callback)
Register a callback for when a message group is expired through MessageGroupStore.expireMessageGroups(long) . |
void |
setExpiryCallbacks(java.util.Collection<MessageGroupCallback> expiryCallbacks)
Convenient injection point for expiry callbacks in the message store. |
void |
setTimeoutOnIdle(boolean timeoutOnIdle)
Allows you to override the rule for the timeout calculation. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.springframework.integration.store.MessageGroupStore |
---|
addMessageToGroup, completeGroup, getMessageGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessageFromGroup, removeMessageGroup, setLastReleasedSequenceNumberForGroup |
Methods inherited from interface java.lang.Iterable |
---|
iterator |
Field Detail |
---|
protected final org.apache.commons.logging.Log logger
Constructor Detail |
---|
public AbstractMessageGroupStore()
Method Detail |
---|
public void setExpiryCallbacks(java.util.Collection<MessageGroupCallback> expiryCallbacks)
registerMessageGroupExpiryCallback(MessageGroupCallback)
.
expiryCallbacks
- the expiry callbacks to addpublic boolean isTimeoutOnIdle()
public void setTimeoutOnIdle(boolean timeoutOnIdle)
MessageGroup
was created. If you want the timeout to be based on the time
the MessageGroup
was idling (e.g., inactive from the last update) invoke this method with 'true'.
Default is 'false'.
public void registerMessageGroupExpiryCallback(MessageGroupCallback callback)
MessageGroupStore
MessageGroupStore.expireMessageGroups(long)
.
registerMessageGroupExpiryCallback
in interface MessageGroupStore
callback
- a callback to execute when a message group is cleaned uppublic int expireMessageGroups(long timeout)
MessageGroupStore
expireMessageGroups
in interface MessageGroupStore
timeout
- the timeout threshold to use
MessageGroupStore.registerMessageGroupExpiryCallback(MessageGroupCallback)
@ManagedAttribute public int getMessageCountForAllMessageGroups()
MessageGroupStore
getMessageCountForAllMessageGroups
in interface MessageGroupStore
@ManagedAttribute public int getMessageGroupCount()
MessageGroupStore
getMessageGroupCount
in interface MessageGroupStore
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |