From f089942c7b8570a9c519b50426ef944030dd2b2a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=B1=AA=E4=BA=91=E6=98=8A?= <yunhao.wang@estsh.com>
Date: Sun, 16 Jun 2019 18:06:49 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BA=8B=E4=BB=B6=E7=8E=B0=E8=B1=A1=E5=9F=BA?=
 =?UTF-8?q?=E7=A1=80=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../core/apiservice/mq/WYHQueueReceiver.java       | 49 ----------------------
 1 file changed, 49 deletions(-)
 delete mode 100644 modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/WYHQueueReceiver.java

diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/WYHQueueReceiver.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/WYHQueueReceiver.java
deleted file mode 100644
index 303141d..0000000
--- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/WYHQueueReceiver.java
+++ /dev/null
@@ -1,49 +0,0 @@
-package cn.estsh.i3plus.core.apiservice.mq;
-
-import com.rabbitmq.client.Channel;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.stereotype.Component;
-
-import java.io.IOException;
-
-/**
- * @Description : 定时任务通道业务处理
- * @Reference :
- * @Author : yunhao
- * @CreateDate : 2018-12-20 21:56
- * @Modify:
- **/
-@Component
-public class WYHQueueReceiver {
-
-    private static final Logger LOGGER = LoggerFactory.getLogger(WYHQueueReceiver.class);
-
-
-    /**
-     * 定时任务通道处理
-     *
-     * @param data      系统消息信息
-     * @param channel   通道
-     * @param message   消息
-     */
-    @RabbitListener(queues = "WYH")
-    public void processSchedule(String data, Channel channel, Message message) {
-        try {
-            System.out.println("队列消息接受成功========" + data);
-            //信息已处理
-            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
-        } catch (IOException e) {
-            LOGGER.error("【MQ-IMPP_MESSAGE_MAIL_QUEUE】处理出错：{}", e.getMessage(), e);
-            //丢弃这条消息
-            try {
-                // 未成功处理，重新发送
-                channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
-            } catch (IOException e1) {
-                e1.printStackTrace();
-            }
-        }
-    }
-}