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>, IntegrationPattern, BasicMessageGroupStore, MessageGroupStore, MessageStore

public class HazelcastMessageStore
extends AbstractKeyValueMessageStore

The Hazelcast IMap-based AbstractKeyValueMessageStore implementation.

Author:

Vinicius Carvalho, Artem Bilan

Nested Class Summary

Nested classes/interfaces inherited from interface MessageGroupStore

MessageGroupStore.MessageGroupCallback

Field Summary

Fields inherited from class AbstractKeyValueMessageStore

MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIX

Fields inherited from class AbstractMessageGroupStore

INTERRUPTED_WHILE_OBTAINING_LOCK, logger

Constructor Summary

Constructors

Constructor	Description
HazelcastMessageStore(com.hazelcast.core.HazelcastInstance hazelcastInstance)
HazelcastMessageStore(com.hazelcast.map.IMap<Object,Object> map)

Method Summary

Modifier and Type	Method	Description
protected @Nullable Collection<?>	doListKeys(String keyPattern)
protected Object	doRemove(Object id)
protected void	doRemoveAll(Collection<Object> ids)
protected @Nullable Object	doRetrieve(Object id)
protected void	doStore(Object id, Object objectToStore)
protected void	doStoreIfAbsent(Object id, Object objectToStore)

Methods inherited from class AbstractKeyValueMessageStore

addMessage, doAddMessage, doAddMessage, doAddMessagesToGroup, doCompleteGroup, doPollMessageFromGroup, doRemoveMessageFromGroupById, doRemoveMessageGroup, doRemoveMessagesFromGroup, doSetGroupCondition, doSetLastReleasedSequenceNumberForGroup, getGroupMetadata, getGroupPrefix, getMessage, getMessageCount, getMessageFromGroup, getMessageGroup, getMessageMetadata, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, removeMessage, streamMessagesForGroup

Methods inherited from class AbstractMessageGroupStore

addMessagesToGroup, addMessageToGroup, completeGroup, copy, executeLocked, executeLocked, expireMessageGroups, getLockRegistry, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, pollMessageFromGroup, registerMessageGroupExpiryCallback, removeMessageFromGroupById, removeMessageGroup, removeMessagesFromGroup, removeMessagesFromGroup, setExpiryCallbacks, setGroupCondition, setLastReleasedSequenceNumberForGroup, setLazyLoadMessageGroups, setLockRegistry, setTimeoutOnIdle

Methods inherited from class AbstractBatchingMessageGroupStore

getRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSize

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Iterable

forEach, spliterator

Methods inherited from interface MessageStore

getIntegrationPatternType

Constructor Details

HazelcastMessageStore

public HazelcastMessageStore(com.hazelcast.core.HazelcastInstance hazelcastInstance)

HazelcastMessageStore

public HazelcastMessageStore(com.hazelcast.map.IMap<Object,Object> map)

Method Details

doRetrieve

protected @Nullable Object doRetrieve(Object id)

Specified by:

doRetrieve in class AbstractKeyValueMessageStore

doStore

protected void doStore(Object id,
 Object objectToStore)

Specified by:

doStore in class AbstractKeyValueMessageStore

doStoreIfAbsent

protected void doStoreIfAbsent(Object id,
 Object objectToStore)

Specified by:

doStoreIfAbsent in class AbstractKeyValueMessageStore

doRemoveAll

protected void doRemoveAll(Collection<Object> ids)

Specified by:

doRemoveAll in class AbstractKeyValueMessageStore

doRemove

protected Object doRemove(Object id)

Specified by:

doRemove in class AbstractKeyValueMessageStore

doListKeys

protected @Nullable Collection<?> doListKeys(String keyPattern)

Specified by:

doListKeys in class AbstractKeyValueMessageStore