Package-level declarations
Types
Link copied to clipboard
class OpenTelemetryAMQPChannel(delegate: AMQPChannel, tracer: Tracer, config: TracingConfig = TracingConfig.default()) : AMQPChannel
OpenTelemetry-instrumented wrapper around AMQPChannel.
Link copied to clipboard
class OpenTelemetryAMQPConnection(delegate: AMQPConnection, tracer: Tracer, tracingConfig: TracingConfig = TracingConfig.default()) : AMQPConnection
OpenTelemetry-instrumented wrapper around AMQPConnection.
Link copied to clipboard
object SemanticAttributes
OpenTelemetry semantic conventions for messaging systems.
Link copied to clipboard
object SpanPropagator
Handles W3C Trace Context propagation via AMQP message headers.
Link copied to clipboard
data class TracingConfig(val traceConnectionOperations: Boolean = false, val traceChannelManagementOperations: Boolean = false, val captureMessageBody: Boolean = false, val maxBodySizeToCapture: Int = 1024, val publishSpanNameFormatter: (exchange: String, routingKey: String) -> String = defaultPublishSpanNameFormatter, val consumeSpanNameFormatter: (queue: String) -> String = defaultConsumeSpanNameFormatter)
Configuration options for OpenTelemetry tracing behavior.
Functions
Link copied to clipboard
fun AMQPChannel.withTracing(tracer: Tracer, tracingConfig: TracingConfig = TracingConfig.default()): AMQPChannel
Wraps an existing channel with OpenTelemetry instrumentation.
fun AMQPConnection.withTracing(tracer: Tracer, tracingConfig: TracingConfig = TracingConfig.default()): AMQPConnection
Wraps an existing connection with OpenTelemetry instrumentation.