Package org.axonframework.messaging.queryhandling.tracing

Class DefaultQueryUpdateEmitterSpanFactory

java.lang.Object

org.axonframework.messaging.queryhandling.tracing.DefaultQueryUpdateEmitterSpanFactory

All Implemented Interfaces:

QueryUpdateEmitterSpanFactory

public class DefaultQueryUpdateEmitterSpanFactory
extends Object
implements QueryUpdateEmitterSpanFactory

Default implementation of the QueryUpdateEmitterSpanFactory.

Since:

4.9.0

Author:

Mitchell Herrijgers

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultQueryUpdateEmitterSpanFactory.Builder	Builder class to instantiate a DefaultQueryUpdateEmitterSpanFactory.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DefaultQueryUpdateEmitterSpanFactory(DefaultQueryUpdateEmitterSpanFactory.Builder builder)	Creates a new DefaultQueryUpdateEmitterSpanFactory using the provided builder.

Method Summary

Modifier and Type	Method	Description
static DefaultQueryUpdateEmitterSpanFactory.Builder	builder()	Creates a Builder to be able to create a DefaultQueryUpdateEmitterSpanFactory.
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.
<M extends SubscriptionQueryUpdateMessage> M	propagateContext(M update)	Propagates the context of the current span to the given update message.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DefaultQueryUpdateEmitterSpanFactory

protected DefaultQueryUpdateEmitterSpanFactory(DefaultQueryUpdateEmitterSpanFactory.Builder builder)

Creates a new DefaultQueryUpdateEmitterSpanFactory using the provided builder.

Parameters:

builder - The builder to build the DefaultQueryUpdateEmitterSpanFactory from.

Method Details

builder

public static DefaultQueryUpdateEmitterSpanFactory.Builder builder()

Creates a Builder to be able to create a DefaultQueryUpdateEmitterSpanFactory. The spanFactory is a required field and should be provided.

Returns:

a Builder to be able to create a DefaultQueryUpdateEmitterSpanFactory

createUpdateScheduleEmitSpan

public Span createUpdateScheduleEmitSpan(SubscriptionQueryUpdateMessage update)

Description copied from interface: QueryUpdateEmitterSpanFactory

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

Specified by:

createUpdateScheduleEmitSpan in interface QueryUpdateEmitterSpanFactory

Parameters:

update - The update to create a span for.

Returns:

The created span.

createUpdateEmitSpan

public Span createUpdateEmitSpan(SubscriptionQueryUpdateMessage update)

Description copied from interface: QueryUpdateEmitterSpanFactory

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

Specified by:

createUpdateEmitSpan in interface QueryUpdateEmitterSpanFactory

Parameters:

update - The update to create a span for.

Returns:

The created span.

propagateContext

public <M extends SubscriptionQueryUpdateMessage> M propagateContext(M update)

Description copied from interface: QueryUpdateEmitterSpanFactory

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

Specified by:

propagateContext in interface QueryUpdateEmitterSpanFactory

Type Parameters:

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.