Uses of Interface
org.springframework.integration.store.MessageGroup

Packages that use MessageGroup

org.springframework.integration.aggregator
org.springframework.integration.jdbc
org.springframework.integration.store

Uses of MessageGroup in org.springframework.integration.aggregator

Methods in org.springframework.integration.aggregator with parameters of type MessageGroup

protected Map<String,Object>	AbstractAggregatingMessageGroupProcessor.aggregateHeaders(MessageGroup group) This default implementation simply returns all headers that have no conflicts among the group.
protected Object	DefaultAggregatingMessageGroupProcessor.aggregatePayloads(MessageGroup group, Map<String,Object> headers)
protected Object	ExpressionEvaluatingMessageGroupProcessor.aggregatePayloads(MessageGroup group, Map<String,Object> headers) Evaluate the expression provided on the unmarked messages (a collection) in the group, and delegate to the MessagingTemplate to send downstream.
protected Object	MethodInvokingMessageGroupProcessor.aggregatePayloads(MessageGroup group, Map<String,Object> headers)
protected abstract Object	AbstractAggregatingMessageGroupProcessor.aggregatePayloads(MessageGroup group, Map<String,Object> defaultHeaders)
boolean	ReleaseStrategy.canRelease(MessageGroup group)
boolean	TimeoutCountSequenceSizeReleaseStrategy.canRelease(MessageGroup messages)
boolean	SequenceSizeReleaseStrategy.canRelease(MessageGroup messages)
boolean	MethodInvokingReleaseStrategy.canRelease(MessageGroup messages)
boolean	ExpressionEvaluatingReleaseStrategy.canRelease(MessageGroup messages) Evaluate the expression provided on the unmarked messages (a collection) in the group and return the result (must be boolean).
boolean	MessageCountReleaseStrategy.canRelease(MessageGroup group) Release the group if it has more messages than the threshold and has not previously been released.
Object	ResequencingMessageGroupProcessor.processMessageGroup(MessageGroup group)
Object	PassThroughMessageGroupProcessor.processMessageGroup(MessageGroup group)
Object	MessageGroupProcessor.processMessageGroup(MessageGroup group) Process the given MessageGroup.
Object	AbstractAggregatingMessageGroupProcessor.processMessageGroup(MessageGroup group)

Uses of MessageGroup in org.springframework.integration.jdbc

Methods in org.springframework.integration.jdbc that return MessageGroup

MessageGroup	JdbcMessageStore.addMessageToGroup(Object groupId, Message<?> message)
MessageGroup	JdbcMessageStore.getMessageGroup(Object groupId)
MessageGroup	JdbcMessageStore.markMessageGroup(MessageGroup group)
MessageGroup	JdbcMessageStore.removeMessageFromGroup(Object groupId, Message<?> messageToMark)

Methods in org.springframework.integration.jdbc that return types with arguments of type MessageGroup

Iterator<MessageGroup>

JdbcMessageStore.iterator()

Methods in org.springframework.integration.jdbc with parameters of type MessageGroup

MessageGroup

JdbcMessageStore.markMessageGroup(MessageGroup group)

Uses of MessageGroup in org.springframework.integration.store

Classes in org.springframework.integration.store that implement MessageGroup

class

SimpleMessageGroup Represents a mutable group of correlated messages that is bound to a certain MessageStore and group id.

Methods in org.springframework.integration.store that return MessageGroup

MessageGroup	MessageGroupStore.addMessageToGroup(Object groupId, Message<?> message) Store a message with an association to a group id.
MessageGroup	SimpleMessageStore.addMessageToGroup(Object groupId, Message<?> message)
MessageGroup	MessageGroupStore.getMessageGroup(Object groupId) Return all Messages currently in the MessageStore that were stored using MessageGroupStore.addMessageToGroup(Object, Message) with this group id.
MessageGroup	SimpleMessageStore.getMessageGroup(Object groupId)
MessageGroup	MessageGroupStore.markMessageGroup(MessageGroup group) Persist the mark on all the messages from the group.
MessageGroup	SimpleMessageStore.markMessageGroup(MessageGroup group)
MessageGroup	MessageGroupStore.removeMessageFromGroup(Object key, Message<?> messageToMark) Persist a mark on a single message from the group.
MessageGroup	SimpleMessageStore.removeMessageFromGroup(Object key, Message<?> messageToMark)

Methods in org.springframework.integration.store that return types with arguments of type MessageGroup

abstract Iterator<MessageGroup>	AbstractMessageGroupStore.iterator()
Iterator<MessageGroup>	SimpleMessageStore.iterator()

Methods in org.springframework.integration.store with parameters of type MessageGroup

void	MessageGroupCallback.execute(MessageGroupStore messageGroupStore, MessageGroup group)
MessageGroup	MessageGroupStore.markMessageGroup(MessageGroup group) Persist the mark on all the messages from the group.
MessageGroup	SimpleMessageStore.markMessageGroup(MessageGroup group)

Constructors in org.springframework.integration.store with parameters of type MessageGroup

SimpleMessageGroup(MessageGroup template)