20191030 注释发送mq的代码，暂时不需要

server/src/main/java/com/pica/cloud/account/account/server/queue/QueueConfig.java

@@ -10,40 +10,40 @@ import org.springframework.context.annotation.Configuration;
  * author:crs
  * Description:消息队列配置
  */
-@Configuration
-public class QueueConfig {
-
-    public final static String QUEUE_NAME = "register_queue_account_13201";
-    public final static String EXCHANGE_NAME = "register_exchange";
-    public final static String ROUTE_KEY_NAME = "register_finish";
-    
-    /**
-     * 创建一个消息队列
-     *
-     * @return
-     */
-    @Bean
-    public Queue queue() {
-        return new Queue(QUEUE_NAME, true, false, true);
-    }
-
-    /**
-     * 创建交换机
-     *
-     * @return
-     */
-    @Bean
-    public TopicExchange directExchange() {
-        return new TopicExchange(EXCHANGE_NAME);
-    }
-
-    /**
-     * 把消息队里和交换机进行绑定
-     *
-     * @return
-     */
-    @Bean
-    public Binding binding() {
-        return BindingBuilder.bind(queue()).to(directExchange()).with(ROUTE_KEY_NAME);
-    }
-}
+//@Configuration
+//public class QueueConfig {
+//
+//    public final static String QUEUE_NAME = "register_queue_account_13201";
+//    public final static String EXCHANGE_NAME = "register_exchange";
+//    public final static String ROUTE_KEY_NAME = "register_finish";
+//
+//    /**
+//     * 创建一个消息队列
+//     *
+//     * @return
+//     */
+//    @Bean
+//    public Queue queue() {
+//        return new Queue(QUEUE_NAME, true, false, true);
+//    }
+//
+//    /**
+//     * 创建交换机
+//     *
+//     * @return
+//     */
+//    @Bean
+//    public TopicExchange directExchange() {
+//        return new TopicExchange(EXCHANGE_NAME);
+//    }
+//
+//    /**
+//     * 把消息队里和交换机进行绑定
+//     *
+//     * @return
+//     */
+//    @Bean
+//    public Binding binding() {
+//        return BindingBuilder.bind(queue()).to(directExchange()).with(ROUTE_KEY_NAME);
+//    }
+//}

server/src/main/java/com/pica/cloud/account/account/server/queue/QueueProducer.java

@@ -9,18 +9,18 @@ import org.springframework.stereotype.Component;
  * author:crs
  * Description:消息生产者
  */
-@Component
-public class QueueProducer {
-
-    @Autowired
-    private AmqpTemplate amqpTemplate;
-
-    /**
-     * 发送消息
-     *
-     * @param message
-     */
-    public void send(byte[] message) {
-        amqpTemplate.convertAndSend(QueueConfig.EXCHANGE_NAME, QueueConfig.ROUTE_KEY_NAME, message);
-    }
-}
+//@Component
+//public class QueueProducer {
+//
+//    @Autowired
+//    private AmqpTemplate amqpTemplate;
+//
+//    /**
+//     * 发送消息
+//     *
+//     * @param message
+//     */
+//    public void send(byte[] message) {
+//        amqpTemplate.convertAndSend(QueueConfig.EXCHANGE_NAME, QueueConfig.ROUTE_KEY_NAME, message);
+//    }
+//}