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