Message Listener Adapter

MessageListenerImpl.kt

@Component
class MessageListenerImpl(
    @Autowired private val saveMessageUseCase: SaveMessageUseCase
): MessageListener {

    private val logger: Logger = LoggerFactory.getLogger(this.javaClass)

    @RabbitListener(queues = ["\${messages.processor.queue.name}"])
    override fun process(event: MessageEvent) {
        logger.debug("operation=process, message='received MessageEvent {}'", event)
        saveMessageUseCase.execute(event.toMessage())
    }
}