Class HazelcastMessageStore

java.lang.Object
org.springframework.integration.store.AbstractBatchingMessageGroupStore
org.springframework.integration.store.AbstractMessageGroupStore
org.springframework.integration.store.AbstractKeyValueMessageStore
org.springframework.integration.hazelcast.store.HazelcastMessageStore
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 HazelcastMessageStore extends org.springframework.integration.store.AbstractKeyValueMessageStore
The Hazelcast IMap-based AbstractKeyValueMessageStore implementation.
  • 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
    HazelcastMessageStore(com.hazelcast.core.HazelcastInstance hazelcastInstance)
     
    HazelcastMessageStore(com.hazelcast.map.IMap<Object,Object> map)
     
  • Method Summary

    Modifier and Type
    Method
    Description
    protected Collection<?>
    doListKeys(String keyPattern)
     
    protected Object
     
    protected void
     
    protected Object
     
    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

    • HazelcastMessageStore

      public HazelcastMessageStore(com.hazelcast.core.HazelcastInstance hazelcastInstance)
    • HazelcastMessageStore

      public HazelcastMessageStore(com.hazelcast.map.IMap<Object,Object> map)
  • 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
    • doRemoveAll

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

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

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