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

Class GemfireMessageStore

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.store.MessageGroupStore

Field Summary

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

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