Package | Description |
---|---|
org.springframework.integration.aggregator |
Provides classes related to message aggregation.
|
org.springframework.integration.jdbc |
Root package of the Spring Integration JDBC module, which contains various
JDBC and Stored Procedure/Function supporting components.
|
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.store |
Provides classes releated to storing messages.
|
Modifier and Type | Method and Description |
---|---|
protected void |
ResequencingMessageHandler.afterRelease(MessageGroup messageGroup,
Collection<Message<?>> completedMessages) |
protected void |
AggregatingMessageHandler.afterRelease(MessageGroup messageGroup,
Collection<Message<?>> completedMessages) |
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 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 |
MethodInvokingMessageGroupProcessor.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 abstract Object |
AbstractAggregatingMessageGroupProcessor.aggregatePayloads(MessageGroup group,
Map<String,Object> defaultHeaders) |
boolean |
ExpressionEvaluatingReleaseStrategy.canRelease(MessageGroup messages)
Evaluate the expression provided on the 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.
|
boolean |
SequenceSizeReleaseStrategy.canRelease(MessageGroup messageGroup) |
boolean |
MethodInvokingReleaseStrategy.canRelease(MessageGroup messages) |
boolean |
TimeoutCountSequenceSizeReleaseStrategy.canRelease(MessageGroup messages) |
boolean |
ReleaseStrategy.canRelease(MessageGroup group) |
Object |
ResequencingMessageGroupProcessor.processMessageGroup(MessageGroup group) |
Object |
PassThroughMessageGroupProcessor.processMessageGroup(MessageGroup group) |
Object |
MessageGroupProcessor.processMessageGroup(MessageGroup group)
Process the given MessageGroup.
|
Object |
AbstractAggregatingMessageGroupProcessor.processMessageGroup(MessageGroup group) |
Modifier and Type | Method and Description |
---|---|
MessageGroup |
JdbcMessageStore.addMessageToGroup(Object groupId,
Message<?> message) |
MessageGroup |
JdbcMessageStore.getMessageGroup(Object groupId) |
MessageGroup |
JdbcMessageStore.removeMessageFromGroup(Object groupId,
Message<?> messageToRemove) |
Modifier and Type | Method and Description |
---|---|
Iterator<MessageGroup> |
JdbcMessageStore.iterator() |
Modifier and Type | Method and Description |
---|---|
MessageGroup |
JdbcChannelMessageStore.addMessageToGroup(Object groupId,
Message<?> message)
Store a message in the database.
|
MessageGroup |
JdbcChannelMessageStore.getMessageGroup(Object groupId)
Not fully used.
|
MessageGroup |
JdbcChannelMessageStore.removeMessageFromGroup(Object groupId,
Message<?> messageToRemove)
Remove a single message from the database.
|
Modifier and Type | Method and Description |
---|---|
Iterator<MessageGroup> |
JdbcChannelMessageStore.iterator()
Method not implemented.
|
Modifier and Type | Method and Description |
---|---|
MessageGroup |
ConfigurableMongoDbMessageStore.addMessageToGroup(Object groupId,
Message<?> message) |
MessageGroup |
MongoDbMessageStore.addMessageToGroup(Object groupId,
Message<?> message) |
MessageGroup |
ConfigurableMongoDbMessageStore.getMessageGroup(Object groupId) |
MessageGroup |
MongoDbMessageStore.getMessageGroup(Object groupId) |
MessageGroup |
ConfigurableMongoDbMessageStore.removeMessageFromGroup(Object groupId,
Message<?> messageToRemove) |
MessageGroup |
MongoDbMessageStore.removeMessageFromGroup(Object groupId,
Message<?> messageToRemove) |
Modifier and Type | Method and Description |
---|---|
Iterator<MessageGroup> |
ConfigurableMongoDbMessageStore.iterator() |
Iterator<MessageGroup> |
MongoDbMessageStore.iterator() |
Modifier and Type | Class and Description |
---|---|
class |
SimpleMessageGroup
Represents a mutable group of correlated messages that is bound to a certain
MessageStore and group id. |
Modifier and Type | Method and Description |
---|---|
MessageGroup |
MessageGroupStore.addMessageToGroup(Object groupId,
Message<?> message)
Store a message with an association to a group id.
|
MessageGroup |
AbstractKeyValueMessageStore.addMessageToGroup(Object groupId,
Message<?> message)
Add a Message to the group with the provided 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 |
AbstractKeyValueMessageStore.getMessageGroup(Object groupId)
Will create a new instance of SimpleMessageGroup if necessary.
|
MessageGroup |
SimpleMessageStore.getMessageGroup(Object groupId) |
MessageGroup |
MessageGroupStore.removeMessageFromGroup(Object key,
Message<?> messageToRemove)
Persist a deletion on a single message from the group.
|
MessageGroup |
AbstractKeyValueMessageStore.removeMessageFromGroup(Object groupId,
Message<?> messageToRemove)
Remove a Message from the group with the provided group ID.
|
MessageGroup |
SimpleMessageStore.removeMessageFromGroup(Object groupId,
Message<?> messageToRemove) |
Modifier and Type | Method and Description |
---|---|
Iterator<MessageGroup> |
MessageGroupStore.iterator()
Returns the iterator of currently accumulated
MessageGroup s |
Iterator<MessageGroup> |
AbstractKeyValueMessageStore.iterator() |
Iterator<MessageGroup> |
SimpleMessageStore.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
MessageGroupStore.MessageGroupCallback.execute(MessageGroupStore messageGroupStore,
MessageGroup group) |
Constructor and Description |
---|
MessageGroupMetadata(MessageGroup messageGroup) |
SimpleMessageGroup(MessageGroup messageGroup) |
Copyright © 2017. All rights reserved.