Spring Integration

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

java.lang.Object
  extended by org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
      extended by org.springframework.integration.jdbc.store.channel.PostgresChannelMessageStoreQueryProvider
All Implemented Interfaces:
ChannelMessageStoreQueryProvider

public class PostgresChannelMessageStoreQueryProvider
extends AbstractChannelMessageStoreQueryProvider

Since:
2.2
Author:
Gunnar Hillert

Constructor Summary
PostgresChannelMessageStoreQueryProvider()
           
 
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

PostgresChannelMessageStoreQueryProvider

public PostgresChannelMessageStoreQueryProvider()
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