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, doAddMessage, getGroupMetadata, getGroupPrefix, getMessage, getMessageCount, getMessageFromGroup, getMessageGroup, getMessageMetadata, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageFromGroupById, 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
-