public interface ChannelMessageStoreQueryProvider
JdbcChannelMessageStore
to provide database-specific queries.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.
|
String getCountAllMessagesInGroupQuery()
String getPollFromGroupExcludeIdsQuery()
String getPollFromGroupQuery()
String getPriorityPollFromGroupExcludeIdsQuery()
String getPriorityPollFromGroupQuery()
String getMessageQuery()
String getMessageCountForRegionQuery()
String getDeleteMessageQuery()
String getCreateMessageQuery()
String getDeleteMessageGroupQuery()