Class OracleChannelMessageStoreQueryProvider
java.lang.Object
org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
org.springframework.integration.jdbc.store.channel.OracleChannelMessageStoreQueryProvider
- All Implemented Interfaces:
ChannelMessageStoreQueryProvider
public class OracleChannelMessageStoreQueryProvider
extends AbstractChannelMessageStoreQueryProvider
Contains Oracle-specific queries for the
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
- Since:
- 2.2
- Author:
- Gunnar Hillert, Artem Bilan, Gary Russell
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionQuery to add a single message to the database.Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.Get the query used to retrieve the oldest message for a channel.Get the query used to retrieve the oldest message by priority for a channel excluding messages that match the provided message ids.Get the query used to retrieve the oldest message by priority for a channel.Methods inherited from class org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
getCountAllMessagesInGroupQuery, getDeleteMessageGroupQuery, getDeleteMessageQuery, getMessageCountForRegionQuery, getMessageQuery
-
Constructor Details
-
OracleChannelMessageStoreQueryProvider
public OracleChannelMessageStoreQueryProvider()
-
-
Method Details
-
getCreateMessageQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Query to add a single message to the database.- Specified by:
getCreateMessageQuery
in interfaceChannelMessageStoreQueryProvider
- Overrides:
getCreateMessageQuery
in classAbstractChannelMessageStoreQueryProvider
- Returns:
- Sql Query
-
getPollFromGroupExcludeIdsQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.- Returns:
- Sql Query
-
getPollFromGroupQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Get the query used to retrieve the oldest message for a channel.- Returns:
- Sql Query
-
getPriorityPollFromGroupExcludeIdsQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Get the query used to retrieve the oldest message by priority for a channel excluding messages that match the provided message ids.- Returns:
- Sql Query
-
getPriorityPollFromGroupQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Get the query used to retrieve the oldest message by priority for a channel.- Returns:
- Sql Query
-