Package org.springframework.integration.hazelcast.store

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

@Deprecated(forRemoval=true,
            since="6.5")
public class HazelcastMessageStore
extends AbstractKeyValueMessageStore

Deprecated, for removal: This API element is subject to removal in a future version.

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

GROUP_ID_MUST_NOT_BE_NULL, INTERRUPTED_WHILE_OBTAINING_LOCK, logger

Constructor Summary

Constructors

Constructor	Description
HazelcastMessageStore(com.hazelcast.core.HazelcastInstance hazelcastInstance)	Deprecated, for removal: This API element is subject to removal in a future version.
HazelcastMessageStore(com.hazelcast.map.IMap<Object,Object> map)	Deprecated, for removal: This API element is subject to removal in a future version.

Method Summary

Modifier and Type	Method	Description
protected Collection<?>	doListKeys(String keyPattern)	Deprecated, for removal: This API element is subject to removal in a future version.
protected Object	doRemove(Object id)	Deprecated, for removal: This API element is subject to removal in a future version.
protected void	doRemoveAll(Collection<Object> ids)	Deprecated, for removal: This API element is subject to removal in a future version.
protected Object	doRetrieve(Object id)	Deprecated, for removal: This API element is subject to removal in a future version.
protected void	doStore(Object id, Object objectToStore)	Deprecated, for removal: This API element is subject to removal in a future version.
protected void	doStoreIfAbsent(Object id, Object objectToStore)	Deprecated, for removal: This API element is subject to removal in a future version.

Methods inherited from class org.springframework.integration.store.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 org.springframework.integration.store.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 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)

Deprecated, for removal: This API element is subject to removal in a future version.

HazelcastMessageStore

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

Deprecated, for removal: This API element is subject to removal in a future version.

Method Details

doRetrieve

protected Object doRetrieve(Object id)

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

doRetrieve in class AbstractKeyValueMessageStore

doStore

protected void doStore(Object id,
 Object objectToStore)

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

doStore in class AbstractKeyValueMessageStore

doStoreIfAbsent

protected void doStoreIfAbsent(Object id,
 Object objectToStore)

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

doStoreIfAbsent in class AbstractKeyValueMessageStore

doRemoveAll

protected void doRemoveAll(Collection<Object> ids)

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

doRemoveAll in class AbstractKeyValueMessageStore

doRemove

protected Object doRemove(Object id)

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

doRemove in class AbstractKeyValueMessageStore

doListKeys

protected Collection<?> doListKeys(String keyPattern)

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

doListKeys in class AbstractKeyValueMessageStore