public class MySqlChannelMessageStoreQueryProvider extends AbstractChannelMessageStoreQueryProvider
Constructor and Description |
---|
MySqlChannelMessageStoreQueryProvider() |
Modifier and Type | Method and Description |
---|---|
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.
|
getCountAllMessagesInGroupQuery, getCreateMessageQuery, getDeleteMessageGroupQuery, getDeleteMessageQuery, getMessageCountForRegionQuery, getMessageQuery
public MySqlChannelMessageStoreQueryProvider()
public String getPollFromGroupExcludeIdsQuery()
ChannelMessageStoreQueryProvider
getPollFromGroupExcludeIdsQuery
in interface ChannelMessageStoreQueryProvider
getPollFromGroupExcludeIdsQuery
in class AbstractChannelMessageStoreQueryProvider
public String getPollFromGroupQuery()
ChannelMessageStoreQueryProvider
getPollFromGroupQuery
in interface ChannelMessageStoreQueryProvider
getPollFromGroupQuery
in class AbstractChannelMessageStoreQueryProvider
Copyright © 2018. All rights reserved.