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 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 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
-