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
  • Method Summary

    Modifier and Type Method 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.
    java.lang.String getPriorityPollFromGroupExcludeIdsQuery()
    Get the query used to retrieve the oldest message by priority for a channel excluding messages that match the provided message ids.
    java.lang.String getPriorityPollFromGroupQuery()
    Get the query used to retrieve the oldest message by priority for a channel.
  • Method Details

    • 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
    • getPriorityPollFromGroupExcludeIdsQuery

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

      java.lang.String getPriorityPollFromGroupQuery()
      Get the query used to retrieve the oldest message by priority 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