Package org.springframework.integration.gemfire.store

Class GemfireMessageStore

java.lang.Object

org.springframework.integration.store.AbstractBatchingMessageGroupStore

org.springframework.integration.store.AbstractMessageGroupStore

org.springframework.integration.store.AbstractKeyValueMessageStore

org.springframework.integration.gemfire.store.GemfireMessageStore

All Implemented Interfaces:

Iterable<MessageGroup>, BasicMessageGroupStore, MessageGroupStore, MessageStore

public class GemfireMessageStore
extends AbstractKeyValueMessageStore

Gemfire implementation of the key/value style MessageStore and MessageGroupStore.

Since:

2.1

Author:

Mark Fisher, Oleg Zhurakousky, David Turanski, Artem Bilan, Gary Russell

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

Constructors

Constructor	Description
GemfireMessageStore(org.apache.geode.cache.Region<Object,Object> messageStoreRegion)	Provides the region to be used for the message store.
GemfireMessageStore(org.apache.geode.cache.Region<Object,Object> messageStoreRegion, String prefix)	Construct a GemfireMessageStore instance based on the provided.

Method Summary

Modifier and Type	Method	Description
protected Collection<?>	doListKeys(String keyPattern)
protected Object	doRemove(Object id)
protected void	doRemoveAll(Collection<Object> ids)
protected Object	doRetrieve(Object id)
protected void	doStore(Object id, Object objectToStore)
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

GemfireMessageStore

public GemfireMessageStore(org.apache.geode.cache.Region<Object,Object> messageStoreRegion)

Provides the region to be used for the message store. This is useful when using a configured region. This is also required if using a client region on a remote cache server.

Parameters:

messageStoreRegion - The region.

GemfireMessageStore

public GemfireMessageStore(org.apache.geode.cache.Region<Object,Object> messageStoreRegion,
 String prefix)

Construct a GemfireMessageStore instance based on the provided.

Parameters:

messageStoreRegion - the region to use.

prefix - the key prefix to use, allowing the same region to be used for multiple stores.

Since:

4.3.12

Method Details

doRetrieve

protected 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

doRemove

protected Object doRemove(Object id)

Specified by:

doRemove in class AbstractKeyValueMessageStore

doRemoveAll

protected void doRemoveAll(Collection<Object> ids)

Specified by:

doRemoveAll in class AbstractKeyValueMessageStore

doListKeys

protected Collection<?> doListKeys(String keyPattern)

Specified by:

doListKeys in class AbstractKeyValueMessageStore