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

OpenTelemetryAMQPChannel

class OpenTelemetryAMQPChannel(delegate: <Error class: unknown class>, tracer: <Error class: unknown class>, config: TracingConfig = TracingConfig.default())

OpenTelemetry-instrumented wrapper around AMQPChannel.

This class automatically creates spans for message publishing and consumption operations, and propagates trace context through AMQP message headers using W3C Trace Context format.

Constructors

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

Functions

basicConsume

open suspend fun basicConsume(queue: String, consumerTag: String, noAck: Boolean, exclusive: Boolean, arguments: <Error class: unknown class>, onDelivery: suspend (<Error class: unknown class>) -> Unit, onCanceled: suspend (<Error class: unknown class>) -> Unit): <Error class: unknown class>

basicGet

open suspend fun basicGet(queue: String, noAck: Boolean): <Error class: unknown class>

basicPublish

open suspend fun basicPublish(body: ByteArray, exchange: String, routingKey: String, mandatory: Boolean, immediate: Boolean, properties: <Error class: unknown class>): <Error class: unknown class>

basicQos

open suspend fun basicQos(count: <Error class: unknown class>, global: Boolean): <Error class: unknown class>

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

exchangeBind

open suspend fun exchangeBind(destination: String, source: String, routingKey: String, arguments: <Error class: unknown class>): <Error class: unknown class>

exchangeDeclare

open suspend fun exchangeDeclare(name: String, type: String, durable: Boolean, autoDelete: Boolean, internal: Boolean, arguments: <Error class: unknown class>): <Error class: unknown class>

exchangeDelete

open suspend fun exchangeDelete(name: String, ifUnused: Boolean): <Error class: unknown class>

open

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

queueBind

open suspend fun queueBind(queue: String, exchange: String, routingKey: String, arguments: <Error class: unknown class>): <Error class: unknown class>

queueDeclare

open suspend fun queueDeclare(name: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, arguments: <Error class: unknown class>): <Error class: unknown class>

queueDelete

open suspend fun queueDelete(name: String, ifUnused: Boolean, ifEmpty: Boolean): <Error class: unknown class>