amqp-client-opentelemetry/dev.kourier.amqp.opentelemetry/OpenTelemetryAMQPConnection

OpenTelemetryAMQPConnection

class OpenTelemetryAMQPConnection(delegate: <Error class: unknown class>, tracer: <Error class: unknown class>, tracingConfig: TracingConfig = TracingConfig.default())

OpenTelemetry-instrumented wrapper around AMQPConnection.

This class wraps an existing AMQP connection and provides automatic tracing for connection operations. All channels opened through this connection will automatically be wrapped with OpenTelemetryAMQPChannel.

Constructors

constructor(delegate: <Error class: unknown class>, tracer: <Error class: unknown class>, tracingConfig: TracingConfig = TracingConfig.default())

Functions

open suspend fun close(reason: String, code: <Error class: unknown class>): <Error class: unknown class>

openChannel

open suspend fun openChannel(): <Error class: unknown class>

sendHeartbeat

open suspend fun sendHeartbeat()