Package org.springframework.integration.jdbc.channel

Interface PostgresChannelMessageTableSubscriber.Subscription

All Known Implementing Classes:
PostgresSubscribableChannel
Enclosing class:
PostgresChannelMessageTableSubscriber
public static interface PostgresChannelMessageTableSubscriber.Subscription
A subscription to a PostgresChannelMessageTableSubscriber for receiving push notifications for new messages that are added to a JdbcChannelMessageStore.

  • Method Summary

    Modifier and Type
    Method
    Description
    Object
    getGroupId()
    Return the group id for which this subscription receives notifications.
    String
    getRegion()
    Return the region for which this subscription receives notifications.
    void
    notifyUpdate()
    Indicate that a message was added to the represented region and group id.

  • Method Details

    • notifyUpdate

      void notifyUpdate()
      Indicate that a message was added to the represented region and group id. Note that this method might also be invoked if there are no new messages to read, for example if another subscription already read those messages or if a new messages might have arrived during a temporary connection loss.

    • getRegion

      String getRegion()
      Return the region for which this subscription receives notifications.
      Returns:
      The relevant region of the JdbcChannelMessageStore.

    • getGroupId

      Object getGroupId()
      Return the group id for which this subscription receives notifications.
      Returns:
      The group id of the PostgresSubscribableChannel.