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:

Iterable<MessageGroup>, Aware, BeanFactoryAware, InitializingBean, BasicMessageGroupStore, MessageGroupStore, MessageStore

public class GemfireMessageStore
extends AbstractKeyValueMessageStore
implements 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<Object,Object> messageStoreRegion) Provides the region to be used for the message store.

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
protected Collection<?>	doListKeys(String keyPattern)
protected Object	doRemove(Object id)
protected Object	doRetrieve(Object id)
protected void	doStore(Object id, 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, getMessageBuilderFactory, getMessageCountForAllMessageGroups, getMessageGroupCount, isTimeoutOnIdle, registerMessageGroupExpiryCallback, setBeanFactory, 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<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(com.gemstone.gemfire.cache.Cache cache)

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

Parameters:

cache - The cache.

Method Detail

setIgnoreJta

public void setIgnoreJta(boolean ignoreJta)

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

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

doRemove

protected Object doRemove(Object id)

Specified by:

doRemove in class AbstractKeyValueMessageStore

doListKeys

protected Collection<?> doListKeys(String keyPattern)

Specified by:

doListKeys in class AbstractKeyValueMessageStore