public class OracleChannelMessageStoreQueryProvider extends AbstractChannelMessageStoreQueryProvider
JdbcChannelMessageStore.
Please ensure that the used JdbcTemplate's fetchSize property is 1.
Fore more details, please see: http://stackoverflow.com/questions/6117254/force-oracle-to-return-top-n-rows-with-skip-locked| Constructor and Description |
|---|
OracleChannelMessageStoreQueryProvider() |
| Modifier and Type | Method and Description |
|---|---|
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.
|
getCountAllMessagesInGroupQuery, getCreateMessageQuery, getDeleteMessageGroupQuery, getDeleteMessageQuery, getMessageCountForRegionQuery, getMessageQuerypublic OracleChannelMessageStoreQueryProvider()
public java.lang.String getPollFromGroupExcludeIdsQuery()
ChannelMessageStoreQueryProvidergetPollFromGroupExcludeIdsQuery in interface ChannelMessageStoreQueryProvidergetPollFromGroupExcludeIdsQuery in class AbstractChannelMessageStoreQueryProviderpublic java.lang.String getPollFromGroupQuery()
ChannelMessageStoreQueryProvidergetPollFromGroupQuery in interface ChannelMessageStoreQueryProvidergetPollFromGroupQuery in class AbstractChannelMessageStoreQueryProvider