Package org.springframework.integration.gemfire.store

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:
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<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, getMessageFromGroup, getMessageGroup, getMessageMetadata, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageFromGroupById, 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 org.springframework.integration.store.AbstractKeyValueMessageStore

    • doStore

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

    • doStoreIfAbsent

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

    • doRemove

      protected Object doRemove(Object id)
      Specified by:
      doRemove in class org.springframework.integration.store.AbstractKeyValueMessageStore

    • doRemoveAll

      protected void doRemoveAll(Collection<Object> ids)
      Specified by:
      doRemoveAll in class org.springframework.integration.store.AbstractKeyValueMessageStore

    • doListKeys

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