public class OracleChannelMessageStoreQueryProvider extends AbstractChannelMessageStoreQueryProvider
JdbcChannelMessageStore. Please
ensure that the used JdbcTemplate's fetchSize
property is 1.
Fore more details, please see: https://stackoverflow.com/questions/6117254/force-oracle-to-return-top-n-rows-with-skip-locked
| Constructor and Description |
|---|
OracleChannelMessageStoreQueryProvider() |
| 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, getMessageQuerypublic OracleChannelMessageStoreQueryProvider()
public String getCreateMessageQuery()
ChannelMessageStoreQueryProvidergetCreateMessageQuery in interface ChannelMessageStoreQueryProvidergetCreateMessageQuery in class AbstractChannelMessageStoreQueryProviderpublic String getPollFromGroupExcludeIdsQuery()
ChannelMessageStoreQueryProviderpublic String getPollFromGroupQuery()
ChannelMessageStoreQueryProviderpublic String getPriorityPollFromGroupExcludeIdsQuery()
ChannelMessageStoreQueryProviderpublic String getPriorityPollFromGroupQuery()
ChannelMessageStoreQueryProvider