public abstract class AbstractChannelMessageStoreQueryProvider extends java.lang.Object implements ChannelMessageStoreQueryProvider
Constructor and Description |
---|
AbstractChannelMessageStoreQueryProvider() |
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.
|
abstract java.lang.String |
getPollFromGroupExcludeIdsQuery()
Get the query used to retrieve the oldest message for a channel excluding
messages that match the provided message ids.
|
abstract java.lang.String |
getPollFromGroupQuery()
Get the query used to retrieve the oldest message for a channel.
|
public AbstractChannelMessageStoreQueryProvider()
public java.lang.String getCountAllMessagesInGroupQuery()
ChannelMessageStoreQueryProvider
getCountAllMessagesInGroupQuery
in interface ChannelMessageStoreQueryProvider
public abstract java.lang.String getPollFromGroupExcludeIdsQuery()
ChannelMessageStoreQueryProvider
getPollFromGroupExcludeIdsQuery
in interface ChannelMessageStoreQueryProvider
public abstract java.lang.String getPollFromGroupQuery()
ChannelMessageStoreQueryProvider
getPollFromGroupQuery
in interface ChannelMessageStoreQueryProvider
public java.lang.String getMessageQuery()
ChannelMessageStoreQueryProvider
getMessageQuery
in interface ChannelMessageStoreQueryProvider
public java.lang.String getMessageCountForRegionQuery()
ChannelMessageStoreQueryProvider
getMessageCountForRegionQuery
in interface ChannelMessageStoreQueryProvider
public java.lang.String getDeleteMessageQuery()
ChannelMessageStoreQueryProvider
getDeleteMessageQuery
in interface ChannelMessageStoreQueryProvider
public java.lang.String getCreateMessageQuery()
ChannelMessageStoreQueryProvider
getCreateMessageQuery
in interface ChannelMessageStoreQueryProvider
public java.lang.String getDeleteMessageGroupQuery()
ChannelMessageStoreQueryProvider
getDeleteMessageGroupQuery
in interface ChannelMessageStoreQueryProvider