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
-
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, wait
Methods 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:ChannelMessageStoreQueryProvider
Get the query used to retrieve a count of all messages currently persisted for a channel.- Specified by:
getCountAllMessagesInGroupQuery
in interfaceChannelMessageStoreQueryProvider
- Returns:
- Sql Query
-
getMessageQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Query that retrieves a message for the provided message id, channel and region.- Specified by:
getMessageQuery
in interfaceChannelMessageStoreQueryProvider
- Returns:
- Sql Query
-
getMessageCountForRegionQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Query that retrieve a count of all messages for a region.- Specified by:
getMessageCountForRegionQuery
in interfaceChannelMessageStoreQueryProvider
- Returns:
- Sql Query
-
getDeleteMessageQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Query to delete a single message from the database.- Specified by:
getDeleteMessageQuery
in interfaceChannelMessageStoreQueryProvider
- Returns:
- Sql Query
-
getCreateMessageQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Query to add a single message to the database.- Specified by:
getCreateMessageQuery
in interfaceChannelMessageStoreQueryProvider
- Returns:
- Sql Query
-
getDeleteMessageGroupQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Query to delete all messages that belong to a specific channel.- Specified by:
getDeleteMessageGroupQuery
in interfaceChannelMessageStoreQueryProvider
- Returns:
- Sql Query
-