Class HazelcastMessageStore
java.lang.Object
org.springframework.integration.store.AbstractBatchingMessageGroupStore
org.springframework.integration.store.AbstractMessageGroupStore
org.springframework.integration.store.AbstractKeyValueMessageStore
org.springframework.integration.hazelcast.store.HazelcastMessageStore
- All Implemented Interfaces:
Iterable<MessageGroup>
,BasicMessageGroupStore
,MessageGroupStore
,MessageStore
The Hazelcast
IMap
-based AbstractKeyValueMessageStore
implementation.- Author:
- Vinicius Carvalho, Artem Bilan
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.springframework.integration.store.MessageGroupStore
MessageGroupStore.MessageGroupCallback
-
Field Summary
Fields inherited from class org.springframework.integration.store.AbstractKeyValueMessageStore
MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIX
Fields inherited from class org.springframework.integration.store.AbstractMessageGroupStore
logger
-
Constructor Summary
ConstructorDescriptionHazelcastMessageStore
(com.hazelcast.core.HazelcastInstance hazelcastInstance) HazelcastMessageStore
(com.hazelcast.map.IMap<Object, Object> map) -
Method Summary
Modifier and TypeMethodDescriptionprotected Collection<?>
doListKeys
(String keyPattern) protected Object
protected void
doRemoveAll
(Collection<Object> ids) protected Object
doRetrieve
(Object id) protected void
protected void
doStoreIfAbsent
(Object id, Object objectToStore) Methods inherited from class org.springframework.integration.store.AbstractKeyValueMessageStore
addMessage, addMessagesToGroup, completeGroup, doAddMessage, getGroupMetadata, getGroupPrefix, getMessage, getMessageCount, getMessageGroup, getMessageMetadata, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageGroup, removeMessagesFromGroup, setGroupCondition, setLastReleasedSequenceNumberForGroup, streamMessagesForGroup
Methods inherited from class org.springframework.integration.store.AbstractMessageGroupStore
addMessageToGroup, copy, expireMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setExpiryCallbacks, setLazyLoadMessageGroups, setTimeoutOnIdle
Methods inherited from class org.springframework.integration.store.AbstractBatchingMessageGroupStore
getRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSize
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface java.lang.Iterable
forEach, spliterator
-
Constructor Details
-
HazelcastMessageStore
public HazelcastMessageStore(com.hazelcast.core.HazelcastInstance hazelcastInstance) -
HazelcastMessageStore
-
-
Method Details
-
doRetrieve
- Specified by:
doRetrieve
in classAbstractKeyValueMessageStore
-
doStore
- Specified by:
doStore
in classAbstractKeyValueMessageStore
-
doStoreIfAbsent
- Specified by:
doStoreIfAbsent
in classAbstractKeyValueMessageStore
-
doRemoveAll
- Specified by:
doRemoveAll
in classAbstractKeyValueMessageStore
-
doRemove
- Specified by:
doRemove
in classAbstractKeyValueMessageStore
-
doListKeys
- Specified by:
doListKeys
in classAbstractKeyValueMessageStore
-