Zhambul

class ReactiveRabbitListenerContainerFactory : SimpleRabbitListenerContainerFactory() {

    override fun createListenerContainer(endpoint: RabbitListenerEndpoint?): SimpleMessageListenerContainer {
        if (endpoint is MethodRabbitListenerEndpoint) {
            val messageHandlerMethodFactory = getField<MessageHandlerMethodFactory>(endpoint, "messageHandlerMethodFactory")
            endpoint.setMessageHandlerMethodFactory(ReactiveMessageHandlerMethodFactory(messageHandlerMethodFactory))
        }
        return super.createListenerContainer(endpoint)
    }
}

Zhambul

.idea
target
*.iml
*.log.*
*.log
.DS_Store
lib