org.springframework.integration.jdbc.store.channel

Interface ChannelMessageStoreQueryProvider

All Known Implementing Classes:

AbstractChannelMessageStoreQueryProvider, DerbyChannelMessageStoreQueryProvider, H2ChannelMessageStoreQueryProvider, HsqlChannelMessageStoreQueryProvider, MySqlChannelMessageStoreQueryProvider, OracleChannelMessageStoreQueryProvider, PostgresChannelMessageStoreQueryProvider, SqlServerChannelMessageStoreQueryProvider

public interface ChannelMessageStoreQueryProvider

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

Since:

2.2

Author:

Gunnar Hillert, Artem Bilan, Gary Russell

Method Summary

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

Method Detail

getCountAllMessagesInGroupQuery

String getCountAllMessagesInGroupQuery()

Get the query used to retrieve a count of all messages currently persisted for a channel.

Returns:

Sql Query

getPollFromGroupExcludeIdsQuery

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

String getPollFromGroupQuery()

Get the query used to retrieve the oldest message for a channel.

Returns:

Sql Query

getPriorityPollFromGroupExcludeIdsQuery

String getPriorityPollFromGroupExcludeIdsQuery()

Get the query used to retrieve the oldest message by priority for a channel excluding messages that match the provided message ids.

Returns:

Sql Query

getPriorityPollFromGroupQuery

String getPriorityPollFromGroupQuery()

Get the query used to retrieve the oldest message by priority for a channel.

Returns:

Sql Query

getMessageQuery

String getMessageQuery()

Query that retrieves a message for the provided message id, channel and region.

Returns:

Sql Query

getMessageCountForRegionQuery

String getMessageCountForRegionQuery()

Query that retrieve a count of all messages for a region.

Returns:

Sql Query

getDeleteMessageQuery

String getDeleteMessageQuery()

Query to delete a single message from the database.

Returns:

Sql Query

getCreateMessageQuery

String getCreateMessageQuery()

Query to add a single message to the database.

Returns:

Sql Query

getDeleteMessageGroupQuery

String getDeleteMessageGroupQuery()

Query to delete all messages that belong to a specific channel.

Returns:

Sql Query