Spring Integration

org.springframework.integration.jdbc.store.channel
Class OracleChannelMessageStoreQueryProvider

java.lang.Object
  extended by org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
      extended by 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
OracleChannelMessageStoreQueryProvider()
           
 
Method Summary
 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

Spring Integration