Manual ack with Spring Cloud Stream RabbitMQ

Question

Я пытаюсь настроить сценарий, когда слушатели будут вручную отправлять ACK в RabbitMQ. У меня есть это в моей заявке.properties

spring.cloud.stream.rabbit.bindings.input.consumer.acknowledge-mode=MANUAL 

Как отправить подтверждение от слушателя? Я вижу от Manual Acknowledgement of Messages : Spring Cloud Stream Kafka, что для Kafka мы создаем объект подтверждения и вызываем его(). Есть ли пример для RabbitMQ, чтобы сделать то же самое?

Answer 1

См. Spring Integration Reference Manual. Сообщение имеет два заголовка: AmqpHeaders.CHANNEL и AmqpHeaders.DELIVERY_TAG.

Вам необходимо позвонить по телефону basicAck, перейдя по ссылке.

Answer 2

@StreamListener(target = BAR) 
public void handlerMethod(@Payload Foo foo, 
          @Header(AmqpHeaders.CHANNEL) Channel channel, 
          @Header(AmqpHeaders.DELIVERY_TAG) Long deliveryTag) { 
    ... 
    channel.basickAck(deliveryTag, false); 
} 

Заголовки автоматически добавляются RabbitMQ, поэтому вы можете использовать их из коробки с настройками.