Package org.springframework.integration.jdbc.store.channel

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

Constructors

Constructor	Description
OracleChannelMessageStoreQueryProvider()

Method Summary

Modifier and Type	Method	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.

Methods inherited from class org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider

getCountAllMessagesInGroupQuery, getDeleteMessageGroupQuery, getDeleteMessageQuery, getMessageCountForRegionQuery, getMessageQuery

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OracleChannelMessageStoreQueryProvider

public OracleChannelMessageStoreQueryProvider()

Method Details

getCreateMessageQuery

public String getCreateMessageQuery()

Description copied from interface: ChannelMessageStoreQueryProvider

Query to add a single message to the database.

Specified by:

getCreateMessageQuery in interface ChannelMessageStoreQueryProvider

Overrides:

getCreateMessageQuery in class AbstractChannelMessageStoreQueryProvider

Returns:

Sql Query

getPollFromGroupExcludeIdsQuery

public String 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

public String getPollFromGroupQuery()

Description copied from interface: ChannelMessageStoreQueryProvider

Get the query used to retrieve the oldest message for a channel.

Returns:

Sql Query

getPriorityPollFromGroupExcludeIdsQuery

public String 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

public String getPriorityPollFromGroupQuery()

Description copied from interface: ChannelMessageStoreQueryProvider

Get the query used to retrieve the oldest message by priority for a channel.

Returns:

Sql Query