public interface ChannelMessageStoreQueryProvider
JdbcChannelMessageStore
to provide database-specific queries.Modifier and Type | Method and Description |
---|---|
java.lang.String |
getCountAllMessagesInGroupQuery()
Get the query used to retrieve a count of all messages currently persisted
for a channel.
|
java.lang.String |
getCreateMessageQuery()
Query to add a single message to the database.
|
java.lang.String |
getDeleteMessageGroupQuery()
Query to delete all messages that belong to a specific channel.
|
java.lang.String |
getDeleteMessageQuery()
Query to delete a single message from the database.
|
java.lang.String |
getMessageCountForRegionQuery()
Query that retrieve a count of all messages for a region.
|
java.lang.String |
getMessageQuery()
Query that retrieves a message for the provided message id, channel and
region.
|
java.lang.String |
getPollFromGroupExcludeIdsQuery()
Get the query used to retrieve the oldest message for a channel excluding
messages that match the provided message ids.
|
java.lang.String |
getPollFromGroupQuery()
Get the query used to retrieve the oldest message for a channel.
|
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.
|
java.lang.String |
getPriorityPollFromGroupQuery()
Get the query used to retrieve the oldest message by priority for a channel.
|
java.lang.String getCountAllMessagesInGroupQuery()
java.lang.String getPollFromGroupExcludeIdsQuery()
java.lang.String getPollFromGroupQuery()
java.lang.String getPriorityPollFromGroupExcludeIdsQuery()
java.lang.String getPriorityPollFromGroupQuery()
java.lang.String getMessageQuery()
java.lang.String getMessageCountForRegionQuery()
java.lang.String getDeleteMessageQuery()
java.lang.String getCreateMessageQuery()
java.lang.String getDeleteMessageGroupQuery()