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

Class AbstractChannelMessageStoreQueryProvider

java.lang.Object

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

All Implemented Interfaces:

ChannelMessageStoreQueryProvider

Direct Known Subclasses:

DerbyChannelMessageStoreQueryProvider, H2ChannelMessageStoreQueryProvider, HsqlChannelMessageStoreQueryProvider, MySqlChannelMessageStoreQueryProvider, OracleChannelMessageStoreQueryProvider, PostgresChannelMessageStoreQueryProvider, SqlServerChannelMessageStoreQueryProvider

public abstract class AbstractChannelMessageStoreQueryProvider
extends Object
implements ChannelMessageStoreQueryProvider

Since:

2.2

Author:

Gunnar Hillert, Artem Bilan

Constructor Summary

Constructors

Constructor	Description
AbstractChannelMessageStoreQueryProvider()

Method Summary

Modifier and Type	Method	Description
String	getCountAllMessagesInGroupQuery()	Get the query used to retrieve a count of all messages currently persisted for a channel.
String	getCreateMessageQuery()	Query to add a single message to the database.
String	getDeleteMessageGroupQuery()	Query to delete all messages that belong to a specific channel.
String	getDeleteMessageQuery()	Query to delete a single message from the database.
String	getMessageCountForRegionQuery()	Query that retrieve a count of all messages for a region.
String	getMessageQuery()	Query that retrieves a message for the provided message id, channel and region.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider

getPollFromGroupExcludeIdsQuery, getPollFromGroupQuery, getPriorityPollFromGroupExcludeIdsQuery, getPriorityPollFromGroupQuery

Constructor Details

AbstractChannelMessageStoreQueryProvider

public AbstractChannelMessageStoreQueryProvider()

Method Details

getCountAllMessagesInGroupQuery

public 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

getMessageQuery

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