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 -
Method Summary
Modifier and TypeMethodDescriptionGet the query used to retrieve a count of all messages currently persisted for a channel.Query to add a single message to the database.Query to delete all messages that belong to a specific channel.Query to delete a single message from the database.Query that retrieve a count of all messages for a region.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, waitMethods inherited from interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider
getPollFromGroupExcludeIdsQuery, getPollFromGroupQuery, getPriorityPollFromGroupExcludeIdsQuery, getPriorityPollFromGroupQuery
-
Constructor Details
-
AbstractChannelMessageStoreQueryProvider
public AbstractChannelMessageStoreQueryProvider()
-
-
Method Details
-
getCountAllMessagesInGroupQuery
Description copied from interface:ChannelMessageStoreQueryProviderGet the query used to retrieve a count of all messages currently persisted for a channel.- Specified by:
getCountAllMessagesInGroupQueryin interfaceChannelMessageStoreQueryProvider- Returns:
- Sql Query
-
getMessageQuery
Description copied from interface:ChannelMessageStoreQueryProviderQuery that retrieves a message for the provided message id, channel and region.- Specified by:
getMessageQueryin interfaceChannelMessageStoreQueryProvider- Returns:
- Sql Query
-
getMessageCountForRegionQuery
Description copied from interface:ChannelMessageStoreQueryProviderQuery that retrieve a count of all messages for a region.- Specified by:
getMessageCountForRegionQueryin interfaceChannelMessageStoreQueryProvider- Returns:
- Sql Query
-
getDeleteMessageQuery
Description copied from interface:ChannelMessageStoreQueryProviderQuery to delete a single message from the database.- Specified by:
getDeleteMessageQueryin interfaceChannelMessageStoreQueryProvider- Returns:
- Sql Query
-
getCreateMessageQuery
Description copied from interface:ChannelMessageStoreQueryProviderQuery to add a single message to the database.- Specified by:
getCreateMessageQueryin interfaceChannelMessageStoreQueryProvider- Returns:
- Sql Query
-
getDeleteMessageGroupQuery
Description copied from interface:ChannelMessageStoreQueryProviderQuery to delete all messages that belong to a specific channel.- Specified by:
getDeleteMessageGroupQueryin interfaceChannelMessageStoreQueryProvider- Returns:
- Sql Query
-