org.springframework.integration.gemfire.store

Class GemfireMessageStore

java.lang.Object

org.springframework.integration.store.AbstractMessageGroupStore

org.springframework.integration.store.AbstractKeyValueMessageStore

org.springframework.integration.gemfire.store.GemfireMessageStore

All Implemented Interfaces:

java.lang.Iterable<MessageGroup>, org.springframework.beans.factory.InitializingBean, MessageGroupStore, MessageStore

public class GemfireMessageStore
extends AbstractKeyValueMessageStore
implements org.springframework.beans.factory.InitializingBean

Gemfire implementation of the key/value style MessageStore and MessageGroupStore

Since:

2.1

Author:

Mark Fisher, Oleg Zhurakousky, David Turanski

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

CREATED_DATE, MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIX

Fields inherited from class org.springframework.integration.store.AbstractMessageGroupStore

logger

Constructor Summary

Constructors

Constructor and Description
GemfireMessageStore(com.gemstone.gemfire.cache.Cache cache) Provides a cache reference used to create a message store region named 'messageStoreRegion'
GemfireMessageStore(com.gemstone.gemfire.cache.Region<java.lang.Object,java.lang.Object> messageStoreRegion) Provides the region to be used for the message store.

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
protected java.util.Collection<?>	doListKeys(java.lang.String keyPattern)
protected java.lang.Object	doRemove(java.lang.Object id)
protected java.lang.Object	doRetrieve(java.lang.Object id)
protected void	doStore(java.lang.Object id, java.lang.Object objectToStore)
void	setIgnoreJta(boolean ignoreJta)

Methods inherited from class org.springframework.integration.store.AbstractKeyValueMessageStore

addMessage, addMessageToGroup, completeGroup, getMessage, getMessageCount, getMessageGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageFromGroup, removeMessageGroup, setLastReleasedSequenceNumberForGroup

Methods inherited from class org.springframework.integration.store.AbstractMessageGroupStore

expireMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, isTimeoutOnIdle, registerMessageGroupExpiryCallback, setExpiryCallbacks, setTimeoutOnIdle

Methods inherited from class java.lang.Object

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

Constructor Detail

GemfireMessageStore

public GemfireMessageStore(com.gemstone.gemfire.cache.Region<java.lang.Object,java.lang.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(com.gemstone.gemfire.cache.Cache cache)

Provides a cache reference used to create a message store region named 'messageStoreRegion'

Parameters:

cache -

Method Detail

setIgnoreJta

public void setIgnoreJta(boolean ignoreJta)

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

doRetrieve

protected java.lang.Object doRetrieve(java.lang.Object id)

Specified by:

doRetrieve in class AbstractKeyValueMessageStore

doStore

protected void doStore(java.lang.Object id,
           java.lang.Object objectToStore)

Specified by:

doStore in class AbstractKeyValueMessageStore

doRemove

protected java.lang.Object doRemove(java.lang.Object id)

Specified by:

doRemove in class AbstractKeyValueMessageStore

doListKeys

protected java.util.Collection<?> doListKeys(java.lang.String keyPattern)

Specified by:

doListKeys in class AbstractKeyValueMessageStore