iundarigun

    @Bean
    fun jsonDirectBinding(): Binding {
        return BindingBuilder
            .bind(jsonQueue)
            .to(directExchange())
            .with("TO-JSON-QUEUE")
            .noargs()
    }

iundarigun

    @Bean
    fun messageConverter(objectMapper: ObjectMapper): MessageConverter {
        return Jackson2JsonMessageConverter(objectMapper)
    }

iundarigun

data class Person(
    val name: String,
    val collageCompletedYear: Int?,
    val bornAt: LocalDate,
    val active: Boolean
)

iundarigun

@Service
class BasicListener : MessageListener {

    private val log = LoggerFactory.getLogger(javaClass)

    override fun onMessage(message: Message?) {
        log.info("receive message from ${message?.messageProperties?.consumerQueue}")
        val bodyAsString = message?.body?.let { String(it) } ?: ""
        log.info("body $bodyAsString")
    }

iundarigun

    @Bean
    fun queueBasic(): Queue {
        return QueueBuilder
            .durable("FIRST-QUEUE-BASIC")
            .build()
    }

    @Bean
    fun listenerContainer(): MessageListenerContainer {
        val container = SimpleMessageListenerContainer()

iundarigun

    @PostMapping("{exchange}/{routingKey}")
    fun postOnExchange(
        @PathVariable exchange: String,
        @PathVariable routingKey: String,
        @RequestBody message: String
    ): HttpEntity<Any?> {
        log.info("sending message $message")
        rabbitTemplate.convertAndSend(exchange, routingKey, message)
        return ResponseEntity.ok().build()
    }

iundarigun

@Configuration
class DirectConfig(
    private val firstQueue: Queue,
    private val secondQueue: Queue
) {
    @Bean
    fun directExchange(): Exchange {
        return ExchangeBuilder
            .directExchange("DIRECT-EXCHANGE-BASIC")
            .durable(true)

iundarigun

@Configuration
class QueueConfig {
    @Bean
    fun firstQueue(): Queue {
        return QueueBuilder
            .durable("FIRST-QUEUE-BASIC")
            .build()
    }

    @Bean

iundarigun

@Configuration
class FeignConfiguration(
    private val messageConverters: ObjectFactory<HttpMessageConverters>,
    @Value("\${feign-builder.client.readTimeout:10000}")
    private val readTimeout: Int,
    @Value("\${feign-builder.client.connectionTimeout:10000}")
    private val connectionTimeout: Int
    ) {

    fun feignDecoder(): Decoder {

iundarigun

@Service
class ClientService(private val feignBuilder: Feign.Builder) {

    private val log = LoggerFactory.getLogger(javaClass)

    @Cacheable("someHttpClient")
    fun getClient(url: String): SomeHttpClient {
        log.info("M=QueueBalancer, without cache")
        return feignBuilder.target(SomeHttpClient::class.java, url)
    }