public class HazelcastMessageStore
extends org.springframework.integration.store.AbstractKeyValueMessageStore
IMap-based AbstractKeyValueMessageStore implementation.| Constructor and Description |
|---|
HazelcastMessageStore(com.hazelcast.core.HazelcastInstance hazelcastInstance) |
HazelcastMessageStore(com.hazelcast.core.IMap<java.lang.Object,java.lang.Object> map) |
| Modifier and Type | Method and Description |
|---|---|
protected java.util.Collection<?> |
doListKeys(java.lang.String keyPattern) |
protected java.lang.Object |
doRemove(java.lang.Object id) |
protected java.lang.Object |
doRetrieve(java.lang.Object id) |
protected void |
doStore(java.lang.Object id,
java.lang.Object objectToStore) |
addMessage, addMessagesToGroup, completeGroup, getGroupMetadata, getMessage, getMessageCount, getMessageGroup, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageFromGroup, removeMessageGroup, removeMessagesFromGroup, setLastReleasedSequenceNumberForGroupaddMessageToGroup, copy, expireMessageGroups, getMessageBuilderFactory, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setBeanFactory, setExpiryCallbacks, setLazyLoadMessageGroups, setTimeoutOnIdlegetRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSizepublic HazelcastMessageStore(com.hazelcast.core.HazelcastInstance hazelcastInstance)
public HazelcastMessageStore(com.hazelcast.core.IMap<java.lang.Object,java.lang.Object> map)
protected java.lang.Object doRetrieve(java.lang.Object id)
doRetrieve in class org.springframework.integration.store.AbstractKeyValueMessageStoreprotected void doStore(java.lang.Object id,
java.lang.Object objectToStore)
doStore in class org.springframework.integration.store.AbstractKeyValueMessageStoreprotected java.lang.Object doRemove(java.lang.Object id)
doRemove in class org.springframework.integration.store.AbstractKeyValueMessageStoreprotected java.util.Collection<?> doListKeys(java.lang.String keyPattern)
doListKeys in class org.springframework.integration.store.AbstractKeyValueMessageStore