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: http://stackoverflow.com/questions/6117254/force-oracle-to-return-top-n-rows-with-skip-locked

Since:

2.2

Author:

Gunnar Hillert

Constructor Summary

Constructors

Constructor and Description
OracleChannelMessageStoreQueryProvider()

Method Summary

Methods

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.

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

getCountAllMessagesInGroupQuery, getCreateMessageQuery, getDeleteMessageGroupQuery, getDeleteMessageQuery, getMessageCountForRegionQuery, getMessageQuery

Methods inherited from class java.lang.Object

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

Constructor Detail

OracleChannelMessageStoreQueryProvider

public OracleChannelMessageStoreQueryProvider()

Method Detail

getPollFromGroupExcludeIdsQuery

public java.lang.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.

Specified by:

getPollFromGroupExcludeIdsQuery in interface ChannelMessageStoreQueryProvider

Specified by:

getPollFromGroupExcludeIdsQuery in class AbstractChannelMessageStoreQueryProvider

Returns:

Sql Query

getPollFromGroupQuery

public java.lang.String getPollFromGroupQuery()

Description copied from interface: ChannelMessageStoreQueryProvider

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

Specified by:

getPollFromGroupQuery in interface ChannelMessageStoreQueryProvider

Specified by:

getPollFromGroupQuery in class AbstractChannelMessageStoreQueryProvider

Returns:

Sql Query