Package org.axonframework.messaging.eventhandling.tracing

Class DefaultEventBusSpanFactory

java.lang.Object

org.axonframework.messaging.eventhandling.tracing.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	Description
static class	DefaultEventBusSpanFactory.Builder	Builder class to instantiate a DefaultEventBusSpanFactory.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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.
EventMessage	propagateContext(EventMessage 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 Details

DefaultEventBusSpanFactory

protected DefaultEventBusSpanFactory(DefaultEventBusSpanFactory.Builder builder)

Creates a new DefaultEventBusSpanFactory using the provided builder.

Parameters:

builder - The builder to build the DefaultEventBusSpanFactory from.

Method Details

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 EventMessage propagateContext(EventMessage eventMessage)

Description copied from interface: EventBusSpanFactory

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

Specified by:

propagateContext in interface EventBusSpanFactory

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.