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

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

GemfireMessageStore(com.gemstone.gemfire.cache.Cache cache)

Method Summary

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.Cache 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