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

Packages that use MessageGroup

Package	Description
org.springframework.integration.aggregator	Provides classes related to message aggregation.
org.springframework.integration.config	Base package for configuration.
org.springframework.integration.dsl	Root package of the Spring Integration Java DSL.
org.springframework.integration.file.aggregator	Provides support classes for file-based aggregation logic.
org.springframework.integration.jdbc.store	Provides JDBC-backed Message Store implementations.
org.springframework.integration.mongodb.store	Provides classes related to the MongoDB message store.
org.springframework.integration.redis.store	Provides classes related to the Redis message store.
org.springframework.integration.store	Provides classes releated to storing messages.

Uses of MessageGroup in org.springframework.integration.aggregator

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

Modifier and Type	Class	Description
protected static class	AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup

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

Modifier and Type	Method	Description
protected MessageGroup	AbstractCorrelatingMessageHandler.store(Object correlationKey, Message<?> message)

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

Modifier and Type	Method	Description
protected Function<MessageGroup,Map<String,Object>>	AbstractAggregatingMessageGroupProcessor.getHeadersFunction()

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

Modifier and Type	Method	Description
protected abstract void	AbstractCorrelatingMessageHandler.afterRelease(MessageGroup group, Collection<Message<?>> completedMessages)	Allows you to provide additional logic that needs to be performed after the MessageGroup was released.
protected void	AbstractCorrelatingMessageHandler.afterRelease(MessageGroup group, Collection<Message<?>> completedMessages, boolean timeout)	Subclasses may override if special action is needed because the group was released or discarded due to a timeout.
protected void	AggregatingMessageHandler.afterRelease(MessageGroup messageGroup, Collection<Message<?>> completedMessages)	Complete the group and remove all its messages.
protected void	ResequencingMessageHandler.afterRelease(MessageGroup messageGroup, Collection<Message<?>> completedMessages)
protected void	ResequencingMessageHandler.afterRelease(MessageGroup messageGroup, Collection<Message<?>> completedMessages, boolean timeout)	Perform group removal if its size is equal to the sequenceSize.
protected Map<String,Object>	AbstractAggregatingMessageGroupProcessor.aggregateHeaders(MessageGroup group)	This default implementation simply returns all headers that have no conflicts among the group.
protected abstract Object	AbstractAggregatingMessageGroupProcessor.aggregatePayloads(MessageGroup group, Map<String,Object> defaultHeaders)
protected final 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 messages (a collection) in the group, and delegate to the MessagingTemplate to send downstream.
protected final Object	MethodInvokingMessageGroupProcessor.aggregatePayloads(MessageGroup group, Map<String,Object> headers)
Map<String,Object>	DefaultAggregateHeadersFunction.apply(MessageGroup messageGroup)
boolean	ExpressionEvaluatingReleaseStrategy.canRelease(MessageGroup messages)	Evaluate the expression provided on the MessageGroup 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.
boolean	MethodInvokingReleaseStrategy.canRelease(MessageGroup messages)
boolean	ReleaseStrategy.canRelease(MessageGroup group)
boolean	SequenceSizeReleaseStrategy.canRelease(MessageGroup messageGroup)
boolean	SimpleSequenceSizeReleaseStrategy.canRelease(MessageGroup group)
boolean	TimeoutCountSequenceSizeReleaseStrategy.canRelease(MessageGroup messages)
protected void	AbstractCorrelatingMessageHandler.completeGroup(Object correlationKey, MessageGroup group, Lock lock)
protected Collection<Message<?>>	AbstractCorrelatingMessageHandler.completeGroup(Message<?> message, Object correlationKey, MessageGroup group, Lock lock)
protected void	AbstractCorrelatingMessageHandler.expireGroup(Object correlationKey, MessageGroup group, Lock lock)
protected void	AbstractCorrelatingMessageHandler.forceComplete(MessageGroup group)
protected Object	AbstractCorrelatingMessageHandler.obtainGroupTimeout(MessageGroup group)
final Object	AbstractAggregatingMessageGroupProcessor.processMessageGroup(MessageGroup group)
Object	DelegatingMessageGroupProcessor.processMessageGroup(MessageGroup group)
Object	MessageGroupProcessor.processMessageGroup(MessageGroup group)	Process the given MessageGroup.
Object	ResequencingMessageGroupProcessor.processMessageGroup(MessageGroup group)
Object	SimpleMessageGroupProcessor.processMessageGroup(MessageGroup group)
protected void	AbstractCorrelatingMessageHandler.remove(MessageGroup group)

Method parameters in org.springframework.integration.aggregator with type arguments of type MessageGroup

Modifier and Type	Method	Description
void	AbstractAggregatingMessageGroupProcessor.setHeadersFunction(Function<MessageGroup,Map<String,Object>> headersFunction)	Specify a Function to map MessageGroup into composed headers for output message.

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

Modifier	Constructor	Description
	SequenceAwareMessageGroup(MessageGroup messageGroup)

Constructor parameters in org.springframework.integration.aggregator with type arguments of type MessageGroup

Modifier	Constructor	Description
	DelegatingMessageGroupProcessor(MessageGroupProcessor delegate, Function<MessageGroup,Map<String,Object>> headersFunction)

Uses of MessageGroup in org.springframework.integration.config

Method parameters in org.springframework.integration.config with type arguments of type MessageGroup

Modifier and Type	Method	Description
void	AggregatorFactoryBean.setHeadersFunction(Function<MessageGroup,Map<String,Object>> headersFunction)

Uses of MessageGroup in org.springframework.integration.dsl

Method parameters in org.springframework.integration.dsl with type arguments of type MessageGroup

Modifier and Type	Method	Description
S	CorrelationHandlerSpec.groupTimeout(Function<MessageGroup,?> groupTimeoutFunction)	Configure the handler with a function that will be invoked to resolve the group timeout, based on the message group.
AggregatorSpec	AggregatorSpec.headersFunction(Function<MessageGroup,Map<String,Object>> headersFunction)	Configure a Function to merge and compute headers for reply based on the completed MessageGroup.

Uses of MessageGroup in org.springframework.integration.file.aggregator

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

Modifier and Type	Method	Description
protected Object	FileAggregatingMessageGroupProcessor.aggregatePayloads(MessageGroup group, Map<String,Object> defaultHeaders)
boolean	FileAggregator.canRelease(MessageGroup group)
boolean	FileMarkerReleaseStrategy.canRelease(MessageGroup group)
Object	FileAggregator.processMessageGroup(MessageGroup group)

Uses of MessageGroup in org.springframework.integration.jdbc.store

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

Modifier and Type	Method	Description
MessageGroup	JdbcChannelMessageStore.addMessageToGroup(Object groupId, Message<?> message)	Store a message in the database.
MessageGroup	JdbcChannelMessageStore.getMessageGroup(Object groupId)	Not fully used.
MessageGroup	JdbcMessageStore.getMessageGroup(Object groupId)

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

Modifier and Type	Method	Description
Iterator<MessageGroup>	JdbcMessageStore.iterator()

Uses of MessageGroup in org.springframework.integration.mongodb.store

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

Modifier and Type	Method	Description
MessageGroup	ConfigurableMongoDbMessageStore.addMessageToGroup(Object groupId, Message<?> message)
MessageGroup	MongoDbChannelMessageStore.addMessageToGroup(Object groupId, Message<?> message)
MessageGroup	ConfigurableMongoDbMessageStore.getMessageGroup(Object groupId)
MessageGroup	MongoDbChannelMessageStore.getMessageGroup(Object groupId)	Not fully used.
MessageGroup	MongoDbMessageStore.getMessageGroup(Object groupId)

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

Modifier and Type	Method	Description
Iterator<MessageGroup>	AbstractConfigurableMongoDbMessageStore.iterator()
Iterator<MessageGroup>	ConfigurableMongoDbMessageStore.iterator()
Iterator<MessageGroup>	MongoDbMessageStore.iterator()

Uses of MessageGroup in org.springframework.integration.redis.store

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

Modifier and Type	Method	Description
MessageGroup	RedisChannelMessageStore.addMessageToGroup(Object groupId, Message<?> message)
MessageGroup	RedisChannelPriorityMessageStore.addMessageToGroup(Object groupId, Message<?> message)
MessageGroup	RedisChannelMessageStore.getMessageGroup(Object groupId)
MessageGroup	RedisChannelPriorityMessageStore.getMessageGroup(Object groupId)

Uses of MessageGroup in org.springframework.integration.store

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

Modifier and Type	Class	Description
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

Modifier and Type	Method	Description
MessageGroup	AbstractMessageGroupStore.addMessageToGroup(Object groupId, Message<?> message)
MessageGroup	BasicMessageGroupStore.addMessageToGroup(Object groupId, Message<?> message)	Store a message with an association to a group id.
protected MessageGroup	AbstractMessageGroupStore.copy(MessageGroup group)	Used by expireMessageGroups.
protected MessageGroup	SimpleMessageStore.copy(MessageGroup group)
MessageGroup	MessageGroupFactory.create(Object groupId)	Create a MessageGroup instance based on the provided groupId.
MessageGroup	MessageGroupFactory.create(Collection<? extends Message<?>> messages, Object groupId)	Create a MessageGroup instance based on the provided groupId and with the messages for the group.
MessageGroup	MessageGroupFactory.create(Collection<? extends Message<?>> messages, Object groupId, long timestamp, boolean complete)	Create a MessageGroup instance based on the provided groupId and with the messages for the group.
MessageGroup	MessageGroupFactory.create(MessageGroupStore messageGroupStore, Object groupId)	Create a MessageGroup instance based on the provided groupId.
MessageGroup	MessageGroupFactory.create(MessageGroupStore messageGroupStore, Object groupId, long timestamp, boolean complete)	Create a MessageGroup instance based on the provided groupId.
MessageGroup	SimpleMessageGroupFactory.create(Object groupId)
MessageGroup	SimpleMessageGroupFactory.create(Collection<? extends Message<?>> messages, Object groupId)
MessageGroup	SimpleMessageGroupFactory.create(Collection<? extends Message<?>> messages, Object groupId, long timestamp, boolean complete)
MessageGroup	SimpleMessageGroupFactory.create(MessageGroupStore messageGroupStore, Object groupId)
MessageGroup	SimpleMessageGroupFactory.create(MessageGroupStore messageGroupStore, Object groupId, long timestamp, boolean complete)
MessageGroup	AbstractKeyValueMessageStore.getMessageGroup(Object groupId)	Will create a new instance of SimpleMessageGroup if necessary.
MessageGroup	BasicMessageGroupStore.getMessageGroup(Object groupId)	Return all Messages currently in the MessageStore that were stored using BasicMessageGroupStore.addMessageToGroup(Object, Message) with this group id.
MessageGroup	SimpleMessageStore.getMessageGroup(Object groupId)

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

Modifier and Type	Method	Description
Iterator<MessageGroup>	AbstractKeyValueMessageStore.iterator()
Iterator<MessageGroup>	MessageGroupStore.iterator()
Iterator<MessageGroup>	SimpleMessageStore.iterator()

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

Modifier and Type	Method	Description
protected MessageGroup	AbstractMessageGroupStore.copy(MessageGroup group)	Used by expireMessageGroups.
protected MessageGroup	SimpleMessageStore.copy(MessageGroup group)
void	MessageGroupStore.MessageGroupCallback.execute(MessageGroupStore messageGroupStore, MessageGroup group)

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

Modifier	Constructor	Description
	MessageGroupMetadata(MessageGroup messageGroup)
	SimpleMessageGroup(MessageGroup messageGroup)