Spring Integration

org.springframework.integration.jdbc.store.channel
Interface ChannelMessageStoreQueryProvider

All Known Implementing Classes:
AbstractChannelMessageStoreQueryProvider, DerbyChannelMessageStoreQueryProvider, HsqlChannelMessageStoreQueryProvider, MySqlChannelMessageStoreQueryProvider, OracleChannelMessageStoreQueryProvider, PostgresChannelMessageStoreQueryProvider

public interface ChannelMessageStoreQueryProvider

Common interface used in order to configure the JdbcChannelMessageStore to provide database-specific queries.

Since:
2.2
Author:
Gunnar Hillert

Method Summary
 java.lang.String getCountAllMessagesInGroupQuery()
          Get the query used to retrieve a count of all messages currently persisted for a channel.
 java.lang.String getCreateMessageQuery()
          Query to add a single message to the database.
 java.lang.String getDeleteMessageGroupQuery()
          Query to delete all messages that belong to a specific channel.
 java.lang.String getDeleteMessageQuery()
          Query to delete a single message from the database.
 java.lang.String getMessageCountForRegionQuery()
          Query that retrieve a count of all messages for a region.
 java.lang.String getMessageQuery()
          Query that retrieves a message for the provided message id, channel and region.
 java.lang.String getPollFromGroupExcludeIdsQuery()
          Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.
 java.lang.String getPollFromGroupQuery()
          Get the query used to retrieve the oldest message for a channel.
 

Method Detail

getCountAllMessagesInGroupQuery

java.lang.String getCountAllMessagesInGroupQuery()
Get the query used to retrieve a count of all messages currently persisted for a channel.

Returns:
Sql Query

getPollFromGroupExcludeIdsQuery

java.lang.String getPollFromGroupExcludeIdsQuery()
Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.

Returns:
Sql Query

getPollFromGroupQuery

java.lang.String getPollFromGroupQuery()
Get the query used to retrieve the oldest message for a channel.

Returns:
Sql Query

getMessageQuery

java.lang.String getMessageQuery()
Query that retrieves a message for the provided message id, channel and region.

Returns:
Sql Query

getMessageCountForRegionQuery

java.lang.String getMessageCountForRegionQuery()
Query that retrieve a count of all messages for a region.

Returns:
Sql Query

getDeleteMessageQuery

java.lang.String getDeleteMessageQuery()
Query to delete a single message from the database.

Returns:
Sql Query

getCreateMessageQuery

java.lang.String getCreateMessageQuery()
Query to add a single message to the database.

Returns:
Sql Query

getDeleteMessageGroupQuery

java.lang.String getDeleteMessageGroupQuery()
Query to delete all messages that belong to a specific channel.

Returns:
Sql Query

Spring Integration