Class DerbyChannelMessageStoreQueryProvider

java.lang.Object
org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
org.springframework.integration.jdbc.store.channel.DerbyChannelMessageStoreQueryProvider
All Implemented Interfaces:
ChannelMessageStoreQueryProvider

public class DerbyChannelMessageStoreQueryProvider extends AbstractChannelMessageStoreQueryProvider
Since:
2.2 https://blogs.oracle.com/kah/entry/derby_10_5_preview_fetch
Author:
Gunnar Hillert, Artem Bilan, Gary Russell
  • Constructor Details

    • DerbyChannelMessageStoreQueryProvider

      public DerbyChannelMessageStoreQueryProvider()
  • Method Details

    • getPollFromGroupExcludeIdsQuery

      public String getPollFromGroupExcludeIdsQuery()
      Description copied from interface: ChannelMessageStoreQueryProvider
      Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.
      Returns:
      Sql Query
    • getPollFromGroupQuery

      public String getPollFromGroupQuery()
      Description copied from interface: ChannelMessageStoreQueryProvider
      Get the query used to retrieve the oldest message for a channel.
      Returns:
      Sql Query
    • getPriorityPollFromGroupExcludeIdsQuery

      public String getPriorityPollFromGroupExcludeIdsQuery()
      Description copied from interface: ChannelMessageStoreQueryProvider
      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

      public String getPriorityPollFromGroupQuery()
      Description copied from interface: ChannelMessageStoreQueryProvider
      Get the query used to retrieve the oldest message by priority for a channel.
      Returns:
      Sql Query