Spring RabbitMQ-在具有@RabbitListener配置的服务上使用手动通道确认

Channel

@RabbitListener

@RabbitListener(queues = "${eventqueue}")public void receiveMessage(Order order, Channel channel,    @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws Exception {    ...}

并使用了标签

basicAck

basicReject

编辑

@SpringBootApplication@EnableRabbitpublic class So38728668Application {    public static void main(String[] args) throws Exception {        ConfigurableApplicationContext context = SpringApplication.run(So38728668Application.class, args);        context.getBean(RabbitTemplate.class).convertAndSend("", "so38728668", "foo");        context.getBean(Listener.class).latch.await(60, TimeUnit.SECONDS);        context.close();    }    @Bean    public Queue so38728668() {        return new Queue("so38728668");    }    @Bean    public Listener listener() {        return new Listener();    }    public static class Listener {        private final CountDownLatch latch = new CountDownLatch(1);        @RabbitListener(queues = "so38728668")        public void receive(String payload, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag)     throws IOException { System.out.println(payload); channel.basicAck(tag, false); latch.countDown();        }    }}

application.properties：

spring.rabbitmq.listener.acknowledge-mode=manual