public class SqlServerChannelMessageStoreQueryProvider extends AbstractChannelMessageStoreQueryProvider
| Constructor and Description |
|---|
SqlServerChannelMessageStoreQueryProvider() |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getCreateMessageQuery()
Query to add a single message to the database.
|
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.
|
getCountAllMessagesInGroupQuery, getDeleteMessageGroupQuery, getDeleteMessageQuery, getMessageCountForRegionQuery, getMessageQuerypublic SqlServerChannelMessageStoreQueryProvider()
public java.lang.String getPollFromGroupExcludeIdsQuery()
ChannelMessageStoreQueryProviderpublic java.lang.String getPollFromGroupQuery()
ChannelMessageStoreQueryProviderpublic java.lang.String getPriorityPollFromGroupExcludeIdsQuery()
ChannelMessageStoreQueryProviderpublic java.lang.String getPriorityPollFromGroupQuery()
ChannelMessageStoreQueryProviderpublic java.lang.String getCreateMessageQuery()
ChannelMessageStoreQueryProvidergetCreateMessageQuery in interface ChannelMessageStoreQueryProvidergetCreateMessageQuery in class AbstractChannelMessageStoreQueryProvider