Spring Integration

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

java.lang.Object
  extended by org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
All Implemented Interfaces:
ChannelMessageStoreQueryProvider
Direct Known Subclasses:
DerbyChannelMessageStoreQueryProvider, HsqlChannelMessageStoreQueryProvider, MySqlChannelMessageStoreQueryProvider, OracleChannelMessageStoreQueryProvider, PostgresChannelMessageStoreQueryProvider

public abstract class AbstractChannelMessageStoreQueryProvider
extends java.lang.Object
implements ChannelMessageStoreQueryProvider

Since:
2.2
Author:
Gunnar Hillert

Constructor Summary
AbstractChannelMessageStoreQueryProvider()
           
 
Method Summary
 java.lang.String getCountAllMessagesInGroupQuery()
          Get the query used to retrieve a count of all messages currently persisted for a channel.
 java.lang.String getCreateMessageQuery()
          Query to add a single message to the database.
 java.lang.String getDeleteMessageGroupQuery()
          Query to delete all messages that belong to a specific channel.
 java.lang.String getDeleteMessageQuery()
          Query to delete a single message from the database.
 java.lang.String getMessageCountForRegionQuery()
          Query that retrieve a count of all messages for a region.
 java.lang.String getMessageQuery()
          Query that retrieves a message for the provided message id, channel and region.
abstract  java.lang.String getPollFromGroupExcludeIdsQuery()
          Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.
abstract  java.lang.String getPollFromGroupQuery()
          Get the query used to retrieve the oldest message for a channel.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AbstractChannelMessageStoreQueryProvider

public AbstractChannelMessageStoreQueryProvider()
Method Detail

getCountAllMessagesInGroupQuery

public java.lang.String getCountAllMessagesInGroupQuery()
Description copied from interface: ChannelMessageStoreQueryProvider
Get the query used to retrieve a count of all messages currently persisted for a channel.

Specified by:
getCountAllMessagesInGroupQuery in interface ChannelMessageStoreQueryProvider
Returns:
Sql Query

getPollFromGroupExcludeIdsQuery

public abstract 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
Returns:
Sql Query

getPollFromGroupQuery

public abstract 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
Returns:
Sql Query

getMessageQuery

public java.lang.String getMessageQuery()
Description copied from interface: ChannelMessageStoreQueryProvider
Query that retrieves a message for the provided message id, channel and region.

Specified by:
getMessageQuery in interface ChannelMessageStoreQueryProvider
Returns:
Sql Query

getMessageCountForRegionQuery

public java.lang.String getMessageCountForRegionQuery()
Description copied from interface: ChannelMessageStoreQueryProvider
Query that retrieve a count of all messages for a region.

Specified by:
getMessageCountForRegionQuery in interface ChannelMessageStoreQueryProvider
Returns:
Sql Query

getDeleteMessageQuery

public java.lang.String getDeleteMessageQuery()
Description copied from interface: ChannelMessageStoreQueryProvider
Query to delete a single message from the database.

Specified by:
getDeleteMessageQuery in interface ChannelMessageStoreQueryProvider
Returns:
Sql Query

getCreateMessageQuery

public java.lang.String getCreateMessageQuery()
Description copied from interface: ChannelMessageStoreQueryProvider
Query to add a single message to the database.

Specified by:
getCreateMessageQuery in interface ChannelMessageStoreQueryProvider
Returns:
Sql Query

getDeleteMessageGroupQuery

public java.lang.String getDeleteMessageGroupQuery()
Description copied from interface: ChannelMessageStoreQueryProvider
Query to delete all messages that belong to a specific channel.

Specified by:
getDeleteMessageGroupQuery in interface ChannelMessageStoreQueryProvider
Returns:
Sql Query

Spring Integration