Package org.axonframework.messaging.queryhandling.tracing

Interface QueryBusSpanFactory

All Known Implementing Classes:
DefaultQueryBusSpanFactory
public interface QueryBusSpanFactory
Span factory that creates spans for the QueryBus. You can customize the spans of the bus by creating your own implementation.
Since:
4.9.0
Author:
Mitchell Herrijgers

  • Method Details

    • createQuerySpan

      Span createQuerySpan(QueryMessage queryMessage, boolean distributed)
      Creates a span for a query.
      Parameters:
      queryMessage - The query message being dispatched.
      distributed - Whether the query is from a distributed source.
      Returns:
      The span for the handling of the query.

    • createSubscriptionQuerySpan

      Span createSubscriptionQuerySpan(QueryMessage queryMessage, boolean distributed)
      Creates a span for a subscription query.
      Parameters:
      queryMessage - The subscription query message being dispatched.
      distributed - Whether the subscription query is from a distributed source.
      Returns:
      The span for the handling of the subscription query.

    • createSubscriptionQueryProcessUpdateSpan

      Span createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage updateMessage, QueryMessage queryMessage)
      Creates a span for processing a subscription query update that has been received from the server.
      Parameters:
      updateMessage - The update message being handled.
      queryMessage - The subscription query message that the update is for.
      Returns:
      The span for the processing of the subscription query update.

    • createStreamingQuerySpan

      Span createStreamingQuerySpan(QueryMessage queryMessage, boolean distributed)
      Creates a span for a streaming query.
      Parameters:
      queryMessage - The query message being dispatched.
      distributed - Whether the query is from a distributed source.
      Returns:
      The span for the handling of the streaming query.

    • createQueryProcessingSpan

      Span createQueryProcessingSpan(QueryMessage queryMessage)
      Creates a span for processing a query. Distributed implementations can use this to create a span for the entire query processing on the handling side.
      Parameters:
      queryMessage - The query message being handled.
      Returns:
      The span for the processing of the query.

    • createResponseProcessingSpan

      Span createResponseProcessingSpan(QueryMessage queryMessage)
      Creates a span for processing a response. Distributed implementations can use this to create a span for the entire response processing on the sending side.
      Parameters:
      queryMessage - The query message the response is for.
      Returns:
      The span for the processing of the response.

    • propagateContext

      <M extends QueryMessage> M propagateContext(M queryMessage)
      Propagates the context of the current span to the given queryMessage.
      Type Parameters:
      M - The type of the query message.
      Parameters:
      queryMessage - The query message to propagate the context to.
      Returns:
      The query message with the context of the current span.