ほぼログ専門

後続の処理が複雑で、勝手にメッセージを消したく無いとかの時。 例はRabbitMQ

@RabbitListener(queues = "QUEUE")
public void receive(Message message, Channel channel) throws IOException {
        String plaintext = new String(message.getBody());

        // 何らかの処理

        // Ackは処理の最後でやりたい
        channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);
}
spring.rabbitmq.listener.simple.acknowledge-mode=MANUAL

このログへのコメント

コメントはありません