春季云流兔子交付确认

Question

如何确保在春季云流兔子中确保交付。我的代码下面： -

class Source {
    MessageChannel output;
    Repository repo;
    @Transactional
    void publisher(Command command){
      repo.save(command);
      output.send(MessageBuilder
                .withPayload(new Event()).build());
    }
}
class Sink {
  @StreamListener(Event.class)
  void eventListener(Event event){
     // method body
  }
}

任何帮助都将不胜感激。

Answer 1

您可以使用兔子消费者属性 spring.cloud.stream.rabbit.bindings.<channelName>.consumer.acknowledgeMode来确认。acknowledgeMode来自Spring AMQP，您可以在此处引用更多文档