org.springframework.integration.gemfire.store
Class GemfireMessageGroupStore

java.lang.Object
  org.springframework.integration.store.AbstractMessageGroupStore
      org.springframework.integration.gemfire.store.KeyValueMessageGroupStore
          org.springframework.integration.gemfire.store.GemfireMessageGroupStore

All Implemented Interfaces:

java.lang.Iterable<MessageGroup>, MessageGroupStore

public class GemfireMessageGroupStore
extends KeyValueMessageGroupStore

Provides GemFire specific support as a backing key-value based MessageGroupStore. Currently, this support is limited to explicitly depending on GemFire Regions, but might conceptually also support optimized key traversal (using a Query, for example).

Since:

2.1

See Also:

org.springframework.integration.gemfire.store.KeyValueMessageGroupStore}

Field Summary

Fields inherited from class org.springframework.integration.gemfire.store.KeyValueMessageGroupStore

groupIdToMessageGroup, marked, unmarked

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

logger

Constructor Summary

GemfireMessageGroupStore(com.gemstone.gemfire.cache.Region<java.lang.Object,KeyValueMessageGroup> groupIdToMessageGroup, com.gemstone.gemfire.cache.Region<java.lang.String,Message<?>> marked, com.gemstone.gemfire.cache.Region<java.lang.String,Message<?>> unmarked)

Method Summary

Methods inherited from class org.springframework.integration.gemfire.store.KeyValueMessageGroupStore

addMessageToGroup, ensureMessageGroupHasReferencesToRegions, getMessageGroup, getMessageGroupInternal, iterator, markMessageFromGroup, markMessageGroup, removeMessageFromGroup, removeMessageGroup

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

expireMessageGroups, getMarkedMessageCountForAllMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, registerMessageGroupExpiryCallback, setExpiryCallbacks

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GemfireMessageGroupStore

public GemfireMessageGroupStore(com.gemstone.gemfire.cache.Region<java.lang.Object,KeyValueMessageGroup> groupIdToMessageGroup,
                                com.gemstone.gemfire.cache.Region<java.lang.String,Message<?>> marked,
                                com.gemstone.gemfire.cache.Region<java.lang.String,Message<?>> unmarked)