public class HsqlChannelMessageStoreQueryProvider extends AbstractChannelMessageStoreQueryProvider
Constructor and Description |
---|
HsqlChannelMessageStoreQueryProvider() |
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, getMessageQuery
public HsqlChannelMessageStoreQueryProvider()
public java.lang.String getCreateMessageQuery()
ChannelMessageStoreQueryProvider
getCreateMessageQuery
in interface ChannelMessageStoreQueryProvider
getCreateMessageQuery
in class AbstractChannelMessageStoreQueryProvider
public java.lang.String getPollFromGroupExcludeIdsQuery()
ChannelMessageStoreQueryProvider
public java.lang.String getPollFromGroupQuery()
ChannelMessageStoreQueryProvider
public java.lang.String getPriorityPollFromGroupExcludeIdsQuery()
ChannelMessageStoreQueryProvider
public java.lang.String getPriorityPollFromGroupQuery()
ChannelMessageStoreQueryProvider