Package org.springframework.integration.store

Class SimpleMessageGroup

java.lang.Object
org.springframework.integration.store.SimpleMessageGroup
All Implemented Interfaces:
MessageGroup
Direct Known Subclasses:
AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup
public class SimpleMessageGroup extends Object implements MessageGroup
Represents a mutable group of correlated messages that is bound to a certain MessageStore and group id. The group will grow during its lifetime, when messages are add(org.springframework.messaging.Message<?>)ed to it. This MessageGroup is thread safe.
Since:
2.0
Author:
Iwein Fuld, Oleg Zhurakousky, Dave Syer, Gary Russell, Artem Bilan, Christian Tzolov

  • Constructor Details

    • SimpleMessageGroup

      public SimpleMessageGroup(Object groupId)

    • SimpleMessageGroup

      public SimpleMessageGroup(Collection<? extends Message<?>> messages, Object groupId)

    • SimpleMessageGroup

      public SimpleMessageGroup(MessageGroup messageGroup)

    • SimpleMessageGroup

      public SimpleMessageGroup(Collection<? extends Message<?>> messages, Object groupId, long timestamp, boolean complete)

    • SimpleMessageGroup

      public SimpleMessageGroup(Collection<Message<?>> internalStore, Collection<? extends Message<?>> messages, Object groupId, long timestamp, boolean complete, boolean storePreLoaded)

  • Method Details

    • getTimestamp

      public long getTimestamp()
      Specified by:
      getTimestamp in interface MessageGroup
      Returns:
      the timestamp (milliseconds since epoch) associated with the creation of this group

    • setLastModified

      public void setLastModified(long lastModified)
      Specified by:
      setLastModified in interface MessageGroup

    • getLastModified

      public long getLastModified()
      Specified by:
      getLastModified in interface MessageGroup
      Returns:
      the timestamp (milliseconds since epoch) associated with the time this group was last updated

    • canAdd

      public boolean canAdd(Message<?> message)
      Description copied from interface: MessageGroup
      Query if the message can be added.
      Specified by:
      canAdd in interface MessageGroup
      Parameters:
      message - The message.
      Returns:
      true if the message can be added.

    • add

      public void add(Message<?> messageToAdd)
      Description copied from interface: MessageGroup
      Add the message to this group.
      Specified by:
      add in interface MessageGroup
      Parameters:
      messageToAdd - the message to add.

    • remove

      public boolean remove(Message<?> message)
      Description copied from interface: MessageGroup
      Remove the message from this group.
      Specified by:
      remove in interface MessageGroup
      Parameters:
      message - the message to remove.
      Returns:
      true if a message was removed.

    • getLastReleasedMessageSequenceNumber

      public int getLastReleasedMessageSequenceNumber()
      Specified by:
      getLastReleasedMessageSequenceNumber in interface MessageGroup
      Returns:
      the sequenceNumber of the last released message. Used in Resequencer use cases only

    • getMessages

      public Collection<Message<?>> getMessages()
      Description copied from interface: MessageGroup
      Return all available Messages from the group at the time of invocation.
      Specified by:
      getMessages in interface MessageGroup
      Returns:
      The messages.

    • setLastReleasedMessageSequenceNumber

      public void setLastReleasedMessageSequenceNumber(int sequenceNumber)
      Specified by:
      setLastReleasedMessageSequenceNumber in interface MessageGroup

    • getGroupId

      public Object getGroupId()
      Specified by:
      getGroupId in interface MessageGroup
      Returns:
      the key that links these messages together

    • isComplete

      public boolean isComplete()
      Specified by:
      isComplete in interface MessageGroup
      Returns:
      true if the group is complete (i.e. no more messages are expected to be added)

    • complete

      public void complete()
      Description copied from interface: MessageGroup
      Complete the group.
      Specified by:
      complete in interface MessageGroup

    • getSequenceSize

      public int getSequenceSize()
      Specified by:
      getSequenceSize in interface MessageGroup
      Returns:
      the size of the sequence expected 0 if unknown

    • size

      public int size()
      Specified by:
      size in interface MessageGroup
      Returns:
      the total number of messages in this group

    • setCondition

      public void setCondition(String condition)
      Description copied from interface: MessageGroup
      Add a condition statement to this group which can be consulted later on, e.g. from the release strategy.
      Specified by:
      setCondition in interface MessageGroup
      Parameters:
      condition - statement which could be consulted later on, e.g. from the release strategy.

    • getCondition

      @Nullable public String getCondition()
      Description copied from interface: MessageGroup
      Return the condition for this group to consult with, e.g. from the release strategy.
      Specified by:
      getCondition in interface MessageGroup
      Returns:
      the condition for this group to consult with, e.g. from the release strategy.

    • getOne

      public Message<?> getOne()
      Specified by:
      getOne in interface MessageGroup
      Returns:
      a single message from the group

    • clear

      public void clear()
      Specified by:
      clear in interface MessageGroup

    • containsSequence

      public boolean containsSequence(Integer sequence)
      Return true if a message with this sequence number header exists in the group.
      Parameters:
      sequence - the sequence number.
      Returns:
      true if it exists.
      Since:
      4.3.7

    • toString

      public String toString()
      Overrides:
      toString in class Object