RabbitMQ with Distributed-Tracing

DistributedTracingConsumer.kt

package com.example.distributed.tracing

import jakarta.annotation.PostConstruct
import org.slf4j.LoggerFactory
import org.springframework.amqp.rabbit.annotation.EnableRabbit
import org.springframework.amqp.rabbit.annotation.RabbitListener
import org.springframework.amqp.rabbit.config.ContainerCustomizer
import org.springframework.amqp.rabbit.core.RabbitTemplate
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.messaging.handler.annotation.Payload
import org.springframework.stereotype.Component


@Component
class DistributedTracingConsumer {

    private val log = LoggerFactory.getLogger(javaClass)

    @RabbitListener(queues = ["\${queue.name}"])
    fun receive(@Payload fileBody: String) {
        log.info("message=$fileBody")
    }
}

/**
 * Ref.:
 * https://github.com/micrometer-metrics/micrometer-samples/blob/main/rabbitmq-consumer/src/main/java/com/example/micrometer/ManualConfiguration.java
 *
 */
@EnableRabbit
@Configuration(proxyBeanMethods = false)
class ManualConfiguration {

    @Bean
    fun containerCustomizer(): ContainerCustomizer<SimpleMessageListenerContainer> {
        return ContainerCustomizer { container: SimpleMessageListenerContainer -> container.setObservationEnabled(true) }
    }

    @Autowired lateinit var rabbitTemplate: RabbitTemplate
    @PostConstruct
    fun setup() {
        rabbitTemplate.setObservationEnabled(true)
    }

}