Package | Description |
---|---|
org.springframework.integration.aggregator |
Provides classes related to message aggregation.
|
org.springframework.integration.handler |
Provides classes implementing various types of message handler.
|
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.redis.store |
Provides classes related to the Redis message store.
|
org.springframework.integration.store |
Provides classes releated to storing messages.
|
Modifier and Type | Field and Description |
---|---|
protected MessageGroupStore |
AbstractCorrelatingMessageHandler.messageStore |
Modifier and Type | Method and Description |
---|---|
protected MessageGroupStore |
AbstractCorrelatingMessageHandler.getMessageStore() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractCorrelatingMessageHandler.setMessageStore(MessageGroupStore store) |
Constructor and Description |
---|
AbstractCorrelatingMessageHandler(MessageGroupProcessor processor,
MessageGroupStore store) |
AbstractCorrelatingMessageHandler(MessageGroupProcessor processor,
MessageGroupStore store,
CorrelationStrategy correlationStrategy,
ReleaseStrategy releaseStrategy) |
AggregatingMessageHandler(MessageGroupProcessor processor,
MessageGroupStore store) |
AggregatingMessageHandler(MessageGroupProcessor processor,
MessageGroupStore store,
CorrelationStrategy correlationStrategy,
ReleaseStrategy releaseStrategy) |
CorrelatingMessageBarrier(MessageGroupStore store) |
ResequencingMessageHandler(MessageGroupProcessor processor,
MessageGroupStore store) |
ResequencingMessageHandler(MessageGroupProcessor processor,
MessageGroupStore store,
CorrelationStrategy correlationStrategy,
ReleaseStrategy releaseStrategy) |
Modifier and Type | Method and Description |
---|---|
void |
DelayHandler.setMessageStore(MessageGroupStore messageStore)
Specify the
MessageGroupStore that should be used to store Messages
while awaiting the delay. |
Modifier and Type | Class and Description |
---|---|
class |
JdbcMessageStore
Implementation of
MessageStore using a relational database via JDBC. |
Modifier and Type | Class and Description |
---|---|
class |
JdbcChannelMessageStore
Channel-specific implementation of
MessageGroupStore using a relational
database via JDBC. |
Modifier and Type | Class and Description |
---|---|
class |
ConfigurableMongoDbMessageStore
An alternate MongoDB
MessageStore and MessageGroupStore which allows the user to
configure the instance of MongoTemplate . |
class |
MongoDbMessageStore
An implementation of both the
MessageStore and MessageGroupStore
strategies that relies upon MongoDB for persistence. |
Modifier and Type | Class and Description |
---|---|
class |
RedisMessageStore
Redis implementation of the key/value style
MessageStore and MessageGroupStore |
Modifier and Type | Class and Description |
---|---|
class |
AbstractKeyValueMessageStore
Base class for implementations of Key/Value style
MessageGroupStore and MessageStore |
class |
AbstractMessageGroupStore |
class |
SimpleMessageStore
Map-based in-memory implementation of
MessageStore and MessageGroupStore . |
Modifier and Type | Method and Description |
---|---|
void |
MessageGroupStore.MessageGroupCallback.execute(MessageGroupStore messageGroupStore,
MessageGroup group) |
void |
MessageGroupStoreReaper.setMessageGroupStore(MessageGroupStore messageGroupStore)
A message group store to expire according the other configurations.
|
Constructor and Description |
---|
MessageGroupQueue(MessageGroupStore messageGroupStore,
Object groupId) |
MessageGroupQueue(MessageGroupStore messageGroupStore,
Object groupId,
int capacity) |
MessageGroupQueue(MessageGroupStore messageGroupStore,
Object groupId,
int capacity,
Lock storeLock) |
MessageGroupQueue(MessageGroupStore messageGroupStore,
Object groupId,
Lock storeLock) |
MessageGroupStoreReaper(MessageGroupStore messageGroupStore) |
Copyright © 2015. All rights reserved.