RabbitmqSpringBoot配置类开启手动签收消息

rabbitmq:

    listener:

      simple:

        ####开启手动ack  

        acknowledge-mode: manual

&＃064;Bean

public SimpleMessageListenerContainer simpleMessageListenerContainer(ConnectionFactory connectionFactory){

        SimpleMessageListenerContainer simpleMessageListenerContainer &＃061; new SimpleMessageListenerContainer(connectionFactory);

        simpleMessageListenerContainer.setQueueNames("my.queue.name");

        //签收模式

        simpleMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode.MANUAL);

        return simpleMessageListenerContainer;

}

&＃064;RabbitListener(queues &＃061; {BusinessConst.APP_SEARCH_QUEUE_NAME})

    public void receiverMessage (Object entity, Message message, Channel channel) throws IOException {

            ...

            //重复收到三条消息之后&＃xff0c;在第三条消息时 以下代码报错&＃xff0c;

            channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);



    }