|
Spring Integration | |||||||||
PREV NEXT | FRAMES NO FRAMES |
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)
|
protected Object |
MethodInvokingMessageGroupProcessor.aggregatePayloads(MessageGroup group)
|
protected abstract Object |
AbstractAggregatingMessageGroupProcessor.aggregatePayloads(MessageGroup group)
|
boolean |
ReleaseStrategy.canRelease(MessageGroup group)
|
boolean |
TimeoutCountSequenceSizeReleaseStrategy.canRelease(MessageGroup messages)
|
boolean |
SequenceSizeReleaseStrategy.canRelease(MessageGroup messages)
|
boolean |
ReleaseStrategyAdapter.canRelease(MessageGroup messages)
|
boolean |
MessageCountReleaseStrategy.canRelease(MessageGroup group)
Release the group if it has more messages than the threshold and has not previously been released. |
void |
ResequencingMessageGroupProcessor.processAndSend(MessageGroup group,
MessagingTemplate messagingTemplate,
MessageChannel outputChannel)
|
void |
PassThroughMessageGroupProcessor.processAndSend(MessageGroup group,
MessagingTemplate messagingTemplate,
MessageChannel outputChannel)
|
void |
MessageGroupProcessor.processAndSend(MessageGroup group,
MessagingTemplate messagingTemplate,
MessageChannel outputChannel)
Process the given group and send the resulting message(s) to the output channel using the messaging template. |
void |
AbstractAggregatingMessageGroupProcessor.processAndSend(MessageGroup group,
MessagingTemplate channelTemplate,
MessageChannel outputChannel)
|
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)
|
|
Spring Integration | |||||||||
PREV NEXT | FRAMES NO FRAMES |