Package org.acemq.amqp.core

Class OpenTelemetrySupport

java.lang.Object

org.acemq.amqp.core.OpenTelemetrySupport

public final class OpenTelemetrySupport
extends Object

Creates the OpenTelemetry sink, in a class of its own.

Separated for the same reason as MicrometerSupport: a reference to an optional type inside a method is resolved when that method runs, so the guard has to live in a different class from the reference it guards.

Method Summary

Modifier and Type	Method	Description
static Telemetry	telemetry(io.opentelemetry.api.OpenTelemetry openTelemetry, String transport)	Emits spans through an OpenTelemetry instance you supply.

Methods inherited from class java.lang.Object

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

Method Details

telemetry

public static Telemetry telemetry(io.opentelemetry.api.OpenTelemetry openTelemetry,
 String transport)

Emits spans through an OpenTelemetry instance you supply.

Parameters:

openTelemetry - the instance to use

transport - transport short name, used as the messaging system attribute

Returns:

a telemetry sink emitting spans