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

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

Since:

2.2

Author:

Gunnar Hillert, Artem Bilan

Constructor Summary

Constructors

Constructor and Description
AbstractChannelMessageStoreQueryProvider()

Method Summary

Modifier and Type	Method and Description
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.

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

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