RabbitMQ

RabbitMQでロストしないようにpublish/consumeする

RabbitMQでメッセージをロストせずにpublish/consumeする方法を軽く調べたのでメモしておく。 consume メッセージの処理が終わったらacknowledgementを返す。 val connection = factory.newConnection(addresses) val channel = connection.createChannel() …