org.axonframework.eventhandling

Class DefaultEventBusSpanFactory

java.lang.Object

org.axonframework.eventhandling.DefaultEventBusSpanFactory

All Implemented Interfaces:

EventBusSpanFactory

public class DefaultEventBusSpanFactory
extends Object
implements EventBusSpanFactory

Default implementation of the EventBusSpanFactory.

Since:

4.9.0

Author:

Mitchell Herrijgers

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
static DefaultEventBusSpanFactory.Builder	builder() Creates a new DefaultEventBusSpanFactory.Builder to build a DefaultEventBusSpanFactory with.
Span	createCommitEventsSpan() Creates a span for the committing of events.
Span	createPublishEventSpan(EventMessage<?> eventMessage) Creates a span for the publishing of an event.
<T> EventMessage<T>	propagateContext(EventMessage<T> eventMessage) Propagates the context of the current span to the given event message.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultEventBusSpanFactory

protected DefaultEventBusSpanFactory(DefaultEventBusSpanFactory.Builder builder)

Creates a new DefaultEventBusSpanFactory using the provided builder.

Parameters:

builder - The builder to build the DefaultEventBusSpanFactory from.

Method Detail

createPublishEventSpan

public Span createPublishEventSpan(EventMessage<?> eventMessage)

Description copied from interface: EventBusSpanFactory

Creates a span for the publishing of an event. This span is created when the event is published on the EventBus. This span does not include the actual commit of the event, this is represented by the EventBusSpanFactory.createCommitEventsSpan() and may occur later.

Specified by:

createPublishEventSpan in interface EventBusSpanFactory

Parameters:

eventMessage - The event message to create a span for.

Returns:

The created span.

createCommitEventsSpan

public Span createCommitEventsSpan()

Description copied from interface: EventBusSpanFactory

Creates a span for the committing of events. This is usually batched and done in the commit phase of a UnitOfWork. If no UnitOfWork is active, the commit is done immediately.

Specified by:

createCommitEventsSpan in interface EventBusSpanFactory

Returns:

The created span.

propagateContext

public <T> EventMessage<T> propagateContext(EventMessage<T> eventMessage)

Description copied from interface: EventBusSpanFactory

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

Specified by:

propagateContext in interface EventBusSpanFactory

Type Parameters:

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

Parameters:

eventMessage - The event message to propagate the context to.

Returns:

The event message with the propagated context.

builder

public static DefaultEventBusSpanFactory.Builder builder()

Creates a new DefaultEventBusSpanFactory.Builder to build a DefaultEventBusSpanFactory with. The spanFactory is a required field and should be provided.

Returns:

The DefaultEventBusSpanFactory.Builder to build a DefaultEventBusSpanFactory with.