org.springframework.integration.jdbc.store.channel

Interface ChannelMessageStoreQueryProvider

All Known Implementing Classes:

AbstractChannelMessageStoreQueryProvider, DerbyChannelMessageStoreQueryProvider, HsqlChannelMessageStoreQueryProvider, MySqlChannelMessageStoreQueryProvider, OracleChannelMessageStoreQueryProvider, PostgresChannelMessageStoreQueryProvider

public interface ChannelMessageStoreQueryProvider

Common interface used in order to configure the JdbcChannelMessageStore to provide database-specific queries.

Since:

2.2

Author:

Gunnar Hillert

Method Summary

Methods

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

Method Detail

getCountAllMessagesInGroupQuery

java.lang.String getCountAllMessagesInGroupQuery()

Get the query used to retrieve a count of all messages currently persisted for a channel.

Returns:

Sql Query

getPollFromGroupExcludeIdsQuery

java.lang.String getPollFromGroupExcludeIdsQuery()

Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.

Returns:

Sql Query

getPollFromGroupQuery

java.lang.String getPollFromGroupQuery()

Get the query used to retrieve the oldest message for a channel.

Returns:

Sql Query

getMessageQuery

java.lang.String getMessageQuery()

Query that retrieves a message for the provided message id, channel and region.

Returns:

Sql Query

getMessageCountForRegionQuery

java.lang.String getMessageCountForRegionQuery()

Query that retrieve a count of all messages for a region.

Returns:

Sql Query

getDeleteMessageQuery

java.lang.String getDeleteMessageQuery()

Query to delete a single message from the database.

Returns:

Sql Query

getCreateMessageQuery

java.lang.String getCreateMessageQuery()

Query to add a single message to the database.

Returns:

Sql Query

getDeleteMessageGroupQuery

java.lang.String getDeleteMessageGroupQuery()

Query to delete all messages that belong to a specific channel.

Returns:

Sql Query