Package org.axonframework.messaging.queryhandling.distributed

Interface QueryBusConnector.Handler

Enclosing interface:
QueryBusConnector
public static interface QueryBusConnector.Handler
Defines a handler for processing query messages and managing subscription queries. Implementations of this interface are responsible for handling incoming query messages and optionally registering handlers for subscription queries to send update.

  • Method Details

    • query

      MessageStream<QueryResponseMessage> query(@Nonnull QueryMessage query)
      Handles the incoming query message.
      Parameters:
      query - The query message to handle.
      Returns:
      a MessageStream containing the responses for the query

    • registerUpdateHandler

      @Nonnull Registration registerUpdateHandler(@Nonnull QueryMessage subscriptionQueryMessage, @Nonnull QueryBusConnector.UpdateCallback updateCallback)
      Registers an update handler for a given subscription query message and its associated update sender.
      Parameters:
      subscriptionQueryMessage - The subscription query message for which update are handled.
      updateCallback - The callback responsible for sending update back to the subscription.
      Returns:
      A Registration instance that can be used to deregister the update handler.