zoukankan      html  css  js  c++  java
  • 是打发付付付付付付

        private static final Logger LOGGER = LoggerFactory.getLogger(MultiConsumer.class);
        private static final String TOPIC_EXCHANGE = "topicExchange1";
        private static final String ROUTING_KEY = "topic.unique.key";
    
        @RabbitListener(
                bindings =
                        {
                                @QueueBinding(
                                        value = @Queue(value = "topicQueue", durable = "true", exclusive = "false", autoDelete = "false"),
                                        exchange = @Exchange(value = TOPIC_EXCHANGE, type = ExchangeTypes.TOPIC), key = ROUTING_KEY),
                                @QueueBinding(
                                        value = @Queue(value = "topicQueue12", durable = "true", exclusive = "false", autoDelete = "false"),
                                        exchange = @Exchange(value = TOPIC_EXCHANGE, type = ExchangeTypes.TOPIC), key = ROUTING_KEY)
                        })
        public void dealMsg(String msg) {
            LOGGER.info("收到到消息:{}", msg);
        }
    
  • 相关阅读:
    十二道MR习题
    十二道MR习题 – 1 – 排序
    初识HBase
    Java内存分析1
    scala学习手记40
    scala学习手记40
    scala学习手记39
    scala学习手记38
    scala学习手记37
    scala学习手记36
  • 原文地址:https://www.cnblogs.com/yw0219/p/8965611.html
Copyright © 2011-2022 走看看