org.axonframework.queryhandling

Interface QueryUpdateEmitterSpanFactory

All Known Implementing Classes:

DefaultQueryUpdateEmitterSpanFactory

public interface QueryUpdateEmitterSpanFactory

Span factory that creates spans for the QueryUpdateEmitter. You can customize the spans of the bus by creating your own implementation.

Since:

4.9.0

Author:

Mitchell Herrijgers

Method Summary

Modifier and Type	Method and Description
Span	createUpdateEmitSpan(SubscriptionQueryUpdateMessage<?> update) Creates a span for the actual emit of a query update when the UnitOfWork commits (or immediately if no UnitOfWork is active).
Span	createUpdateScheduleEmitSpan(SubscriptionQueryUpdateMessage<?> update) Creates a span for the scheduling of emitting a query update.
<T,M extends SubscriptionQueryUpdateMessage<T>> M	propagateContext(M update) Propagates the context of the current span to the given update message.

Method Detail

createUpdateScheduleEmitSpan

Span createUpdateScheduleEmitSpan(SubscriptionQueryUpdateMessage<?> update)

Creates a span for the scheduling of emitting a query update. Query updates are scheduled to be emitted in the commit phase of the UnitOfWork, so these traces are separated to see the proper timings.

Parameters:

update - The update to create a span for.

Returns:

The created span.

createUpdateEmitSpan

Span createUpdateEmitSpan(SubscriptionQueryUpdateMessage<?> update)

Creates a span for the actual emit of a query update when the UnitOfWork commits (or immediately if no UnitOfWork is active).

Parameters:

update - The update to create a span for.

Returns:

The created span.

propagateContext

<T,M extends SubscriptionQueryUpdateMessage<T>> M propagateContext(M update)

Propagates the context of the current span to the given update message.

Type Parameters:

T - The type of the payload of the update message.

M - The type of the update message.

Parameters:

update - The update message to propagate the context to.

Returns:

The update message with the propagated context.