Interface ChannelMessageStoreQueryProvider

All Known Implementing Classes:
AbstractChannelMessageStoreQueryProvider, DerbyChannelMessageStoreQueryProvider, H2ChannelMessageStoreQueryProvider, HsqlChannelMessageStoreQueryProvider, MySqlChannelMessageStoreQueryProvider, OracleChannelMessageStoreQueryProvider, PostgresChannelMessageStoreQueryProvider, SqlServerChannelMessageStoreQueryProvider

public interface ChannelMessageStoreQueryProvider
Common interface used in order to configure the JdbcChannelMessageStore to provide database-specific queries.
Since:
2.2
Author:
Gunnar Hillert, Artem Bilan, Gary Russell
  • Method Details

    • getCountAllMessagesInGroupQuery

      String getCountAllMessagesInGroupQuery()
      Get the query used to retrieve a count of all messages currently persisted for a channel.
      Returns:
      Sql Query
    • getPollFromGroupExcludeIdsQuery

      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

      String getPollFromGroupQuery()
      Get the query used to retrieve the oldest message for a channel.
      Returns:
      Sql Query
    • getPriorityPollFromGroupExcludeIdsQuery

      String getPriorityPollFromGroupExcludeIdsQuery()
      Get the query used to retrieve the oldest message by priority for a channel excluding messages that match the provided message ids.
      Returns:
      Sql Query
    • getPriorityPollFromGroupQuery

      String getPriorityPollFromGroupQuery()
      Get the query used to retrieve the oldest message by priority for a channel.
      Returns:
      Sql Query
    • getMessageQuery

      String getMessageQuery()
      Query that retrieves a message for the provided message id, channel and region.
      Returns:
      Sql Query
    • getMessageCountForRegionQuery

      String getMessageCountForRegionQuery()
      Query that retrieve a count of all messages for a region.
      Returns:
      Sql Query
    • getDeleteMessageQuery

      String getDeleteMessageQuery()
      Query to delete a single message from the database.
      Returns:
      Sql Query
    • getCreateMessageQuery

      String getCreateMessageQuery()
      Query to add a single message to the database.
      Returns:
      Sql Query
    • getDeleteMessageGroupQuery

      String getDeleteMessageGroupQuery()
      Query to delete all messages that belong to a specific channel.
      Returns:
      Sql Query