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:
java.lang.Iterable<org.springframework.integration.store.MessageGroup>, org.springframework.integration.store.BasicMessageGroupStore, org.springframework.integration.store.MessageGroupStore, org.springframework.integration.store.MessageStore

public class GemfireMessageStore
extends org.springframework.integration.store.AbstractKeyValueMessageStore
Gemfire implementation of the key/value style MessageStore and MessageGroupStore
Since:
2.1
  • Nested Class Summary

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

    org.springframework.integration.store.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<java.lang.Object,​java.lang.Object> messageStoreRegion)
    Provides the region to be used for the message store.
    GemfireMessageStore​(org.apache.geode.cache.Region<java.lang.Object,​java.lang.Object> messageStoreRegion, java.lang.String prefix)
    Construct a GemfireMessageStore instance based on the provided
  • Method Summary

    Modifier and Type Method Description
    protected java.util.Collection<?> doListKeys​(java.lang.String keyPattern)  
    protected java.lang.Object doRemove​(java.lang.Object id)  
    protected void doRemoveAll​(java.util.Collection<java.lang.Object> ids)  
    protected java.lang.Object doRetrieve​(java.lang.Object id)  
    protected void doStore​(java.lang.Object id, java.lang.Object objectToStore)  
    protected void doStoreIfAbsent​(java.lang.Object id, java.lang.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, 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<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​(org.apache.geode.cache.Region<java.lang.Object,​java.lang.Object> messageStoreRegion, java.lang.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 java.lang.Object doRetrieve​(java.lang.Object id)
      Specified by:
      doRetrieve in class org.springframework.integration.store.AbstractKeyValueMessageStore
    • doStore

      protected void doStore​(java.lang.Object id, java.lang.Object objectToStore)
      Specified by:
      doStore in class org.springframework.integration.store.AbstractKeyValueMessageStore
    • doStoreIfAbsent

      protected void doStoreIfAbsent​(java.lang.Object id, java.lang.Object objectToStore)
      Specified by:
      doStoreIfAbsent in class org.springframework.integration.store.AbstractKeyValueMessageStore
    • doRemove

      protected java.lang.Object doRemove​(java.lang.Object id)
      Specified by:
      doRemove in class org.springframework.integration.store.AbstractKeyValueMessageStore
    • doRemoveAll

      protected void doRemoveAll​(java.util.Collection<java.lang.Object> ids)
      Specified by:
      doRemoveAll in class org.springframework.integration.store.AbstractKeyValueMessageStore
    • doListKeys

      protected java.util.Collection<?> doListKeys​(java.lang.String keyPattern)
      Specified by:
      doListKeys in class org.springframework.integration.store.AbstractKeyValueMessageStore