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 java.lang.Object implements ChannelMessageStoreQueryProvider
- Since:
- 2.2
-
Constructor Summary
Constructors Constructor Description AbstractChannelMessageStoreQueryProvider() -
Method Summary
Modifier and Type Method Description java.lang.StringgetCountAllMessagesInGroupQuery()Get the query used to retrieve a count of all messages currently persisted for a channel.java.lang.StringgetCreateMessageQuery()Query to add a single message to the database.java.lang.StringgetDeleteMessageGroupQuery()Query to delete all messages that belong to a specific channel.java.lang.StringgetDeleteMessageQuery()Query to delete a single message from the database.java.lang.StringgetMessageCountForRegionQuery()Query that retrieve a count of all messages for a region.java.lang.StringgetMessageQuery()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
public java.lang.String 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
public java.lang.String 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
public java.lang.String getMessageCountForRegionQuery()Description copied from interface:ChannelMessageStoreQueryProviderQuery that retrieve a count of all messages for a region.- Specified by:
getMessageCountForRegionQueryin interfaceChannelMessageStoreQueryProvider- Returns:
- Sql Query
-
getDeleteMessageQuery
public java.lang.String getDeleteMessageQuery()Description copied from interface:ChannelMessageStoreQueryProviderQuery to delete a single message from the database.- Specified by:
getDeleteMessageQueryin interfaceChannelMessageStoreQueryProvider- Returns:
- Sql Query
-
getCreateMessageQuery
public java.lang.String getCreateMessageQuery()Description copied from interface:ChannelMessageStoreQueryProviderQuery to add a single message to the database.- Specified by:
getCreateMessageQueryin interfaceChannelMessageStoreQueryProvider- Returns:
- Sql Query
-
getDeleteMessageGroupQuery
public java.lang.String getDeleteMessageGroupQuery()Description copied from interface:ChannelMessageStoreQueryProviderQuery to delete all messages that belong to a specific channel.- Specified by:
getDeleteMessageGroupQueryin interfaceChannelMessageStoreQueryProvider- Returns:
- Sql Query
-