public class H2ChannelMessageStoreQueryProvider extends AbstractChannelMessageStoreQueryProvider
Constructor and Description |
---|
H2ChannelMessageStoreQueryProvider() |
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 String getCreateMessageQuery()
ChannelMessageStoreQueryProvider
getCreateMessageQuery
in interface ChannelMessageStoreQueryProvider
getCreateMessageQuery
in class AbstractChannelMessageStoreQueryProvider
public String getPollFromGroupExcludeIdsQuery()
ChannelMessageStoreQueryProvider
public String getPollFromGroupQuery()
ChannelMessageStoreQueryProvider
public String getPriorityPollFromGroupExcludeIdsQuery()
ChannelMessageStoreQueryProvider
public String getPriorityPollFromGroupQuery()
ChannelMessageStoreQueryProvider