public abstract class AbstractChannelMessageStoreQueryProvider extends Object implements ChannelMessageStoreQueryProvider
| Constructor and Description |
|---|
AbstractChannelMessageStoreQueryProvider() |
| 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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetPollFromGroupExcludeIdsQuery, getPollFromGroupQuery, getPriorityPollFromGroupExcludeIdsQuery, getPriorityPollFromGroupQuerypublic AbstractChannelMessageStoreQueryProvider()
public String getCountAllMessagesInGroupQuery()
ChannelMessageStoreQueryProvidergetCountAllMessagesInGroupQuery in interface ChannelMessageStoreQueryProviderpublic String getMessageQuery()
ChannelMessageStoreQueryProvidergetMessageQuery in interface ChannelMessageStoreQueryProviderpublic String getMessageCountForRegionQuery()
ChannelMessageStoreQueryProvidergetMessageCountForRegionQuery in interface ChannelMessageStoreQueryProviderpublic String getDeleteMessageQuery()
ChannelMessageStoreQueryProvidergetDeleteMessageQuery in interface ChannelMessageStoreQueryProviderpublic String getCreateMessageQuery()
ChannelMessageStoreQueryProvidergetCreateMessageQuery in interface ChannelMessageStoreQueryProviderpublic String getDeleteMessageGroupQuery()
ChannelMessageStoreQueryProvidergetDeleteMessageGroupQuery in interface ChannelMessageStoreQueryProvider