rabbitMQ高级整合应用第三篇 SimpleMessageListenerContainer

@Bean

public SimpleMessageListenerContainer messageListenerContainer(ConnectionFactory connectionFactory){

    SimpleMessageListenerContainer messageListenerContainer = new SimpleMessageListenerContainer(connectionFactory);

    //添加队列监听

    messageListenerContainer.setQueues(queue001(), queue002(), queue003(), queue_image(), queue_pdf());

    //设置监听数据

    messageListenerContainer.setConcurrentConsumers(1);

    messageListenerContainer.setMaxConcurrentConsumers(5);

    //设置是否重回队列

    messageListenerContainer.setDefaultRequeueRejected(false);

    //设置签收模式 为自动签收

    messageListenerContainer.setAcknowledgeMode(AcknowledgeMode.AUTO);

    //设置客户端tage

    messageListenerContainer.setConsumerTagStrategy(new ConsumerTagStrategy() {

        @Override

        public String createConsumerTag(String queue) {

            return queue+"_"+ UUID.randomUUID().toString();

        }

    });

    //消息

    messageListenerContainer.setMessageListener(new ChannelAwareMessageListener() {

        @Override

        public void onMessage(Message message, Channel channel) throws Exception {

            String msg = new String (message.getBody(),"UTF-8");

            System.out.println("---------->>消息为:"+msg);

        }

    });

    return messageListenerContainer;

}