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 Description StringgetCountAllMessagesInGroupQuery()Get the query used to retrieve a count of all messages currently persisted for a channel.StringgetCreateMessageQuery()Query to add a single message to the database.StringgetDeleteMessageGroupQuery()Query to delete all messages that belong to a specific channel.StringgetDeleteMessageQuery()Query to delete a single message from the database.StringgetMessageCountForRegionQuery()Query that retrieve a count of all messages for a region.StringgetMessageQuery()Query that retrieves a message for the provided message id, channel and region.StringgetPollFromGroupExcludeIdsQuery()Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.StringgetPollFromGroupQuery()Get the query used to retrieve the oldest message for a channel.StringgetPriorityPollFromGroupExcludeIdsQuery()Get the query used to retrieve the oldest message by priority for a channel excluding messages that match the provided message ids.StringgetPriorityPollFromGroupQuery()Get the query used to retrieve the oldest message by priority for a channel.
-
Method Details
-
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
-