org.axonframework.queryhandling

Class DefaultQueryUpdateEmitterSpanFactory

java.lang.Object

org.axonframework.queryhandling.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 and Description
static class	DefaultQueryUpdateEmitterSpanFactory.Builder Builder class to instantiate a DefaultQueryUpdateEmitterSpanFactory.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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.
<T,M extends SubscriptionQueryUpdateMessage<T>> 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 Detail

DefaultQueryUpdateEmitterSpanFactory

protected DefaultQueryUpdateEmitterSpanFactory(DefaultQueryUpdateEmitterSpanFactory.Builder builder)

Creates a new DefaultQueryUpdateEmitterSpanFactory using the provided builder.

Parameters:

builder - The builder to build the DefaultQueryUpdateEmitterSpanFactory from.

Method Detail

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 updates 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 <T,M extends SubscriptionQueryUpdateMessage<T>> 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:

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.