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