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

OpenTelemetryAMQPConnection

class OpenTelemetryAMQPConnection(delegate: AMQPConnection, tracer: Tracer, tracingConfig: TracingConfig = TracingConfig.default()) : AMQPConnection

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: AMQPConnection, tracer: Tracer, tracingConfig: TracingConfig = TracingConfig.default())

Properties

blockedResponses

open override val blockedResponses: Flow<AMQPResponse.Connection.Blocked>

closedResponses

open override val closedResponses: Flow<AMQPResponse.Connection.Closed>

config

open override val config: AMQPConfig

connectionClosed

open override val connectionClosed: Deferred<AMQPException.ConnectionClosed>

connectionOpened

open override val connectionOpened: Deferred<Unit>

openedResponses

open override val openedResponses: Flow<AMQPResponse.Connection.Connected>

state

open override val state: ConnectionState

unblockedResponses

open override val unblockedResponses: Flow<AMQPResponse.Connection.Unblocked>

Functions

open suspend override fun close(reason: String, code: UShort): AMQPResponse.Connection.Closed

openChannel

open suspend override fun openChannel(): AMQPChannel

sendHeartbeat

open suspend override fun sendHeartbeat()

withTracing

fun AMQPConnection.withTracing(tracer: Tracer, tracingConfig: TracingConfig = TracingConfig.default()): AMQPConnection

Wraps an existing connection with OpenTelemetry instrumentation.

write

open suspend override fun write(bytes: ByteArray)

open suspend override fun write(vararg frames: Frame)