Open
Description
Currently the Async* variants of the templates are not covered by this integration.
I worked around this using this:
private fun traceMessage(exchange: Exchange, routingKey: String, message: Message): Message {
val traceHelper = RabbitMqSendTracingHelper(tracer, messageConverter, rabbitMqSpanDecorator)
return traceHelper.doWithTracingHeadersMessage(exchange.name, routingKey, message, ::identity)
}
and then
val listenable = asyncTemplate.convertSendAndReceive<ResponseType>(exchange.name, routingKey, message) {
traceMessage(exchange, routingKey, it)
}