注释消息队列

modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/I3CoreQueueConfig.java

@@ -14,7 +14,6 @@ import org.springframework.context.annotation.Configuration;
  * @CreateDate : 2018-09-26 16:57
  * @Modify:
  **/
-@ConditionalOnExpression("'${spring.core.rabbitmq:true}' == 'true'")
 @Configuration
 public class I3CoreQueueConfig {
     private static final Logger LOGGER = LoggerFactory.getLogger(I3CoreQueueConfig.class);

modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/LetterQueueReceiver.java

@@ -37,8 +37,7 @@ public class LetterQueueReceiver {
      * @param message
      * 发送：rabbitTemplate.convertAndSend(I3CoreQueueConfig.IMPP_MESSAGE_QUEUE, new SysMessage(....));
      */
-//    @RabbitListener(queues = I3CoreQueueConfig.IMPP_MESSAGE_QUEUE)
+//    @RabbitListener(queues = I3CoreQueueConfig.IMPP_MESSAGE_LETTER_QUEUE)
-    @RabbitListener(queues = I3CoreQueueConfig.IMPP_MESSAGE_LETTER_QUEUE)
     public void processImppMessage(RefUserMessage msg, Channel channel, Message message) {
         try {
             LOGGER.info("【MQ-IMPP_MESSAGE_QUEUE】数据接收成功：{}",msg);

modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MailQueueReceiver.java

@@ -2,18 +2,15 @@ package cn.estsh.i3plus.core.apiservice.mq;
 
 import cn.estsh.i3plus.core.api.iservice.busi.ISysMessageService;
 import cn.estsh.i3plus.core.api.iservice.busi.ISysUserService;
-import cn.estsh.i3plus.core.apiservice.serviceimpl.busi.SysMessageService;
 import cn.estsh.i3plus.core.apiservice.util.MailUtil;
 import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
 import cn.estsh.i3plus.pojo.platform.bean.RefUserMessage;
 import cn.estsh.i3plus.pojo.platform.bean.SysMessage;
 import cn.estsh.i3plus.pojo.platform.bean.SysUser;
-import cn.estsh.i3plus.pojo.platform.repository.RefUserMessageRepository;
 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.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -43,10 +40,9 @@ public class MailQueueReceiver {
      * @param channel
      * @param message
      */
-    @RabbitListener(queues = I3CoreQueueConfig.IMPP_MESSAGE_MAIL_QUEUE)
+//    @RabbitListener(queues = I3CoreQueueConfig.IMPP_MESSAGE_MAIL_QUEUE)
     public void processImppMail(RefUserMessage msg, Channel channel, Message message) {
         try {
-            Thread.sleep(18000);
             LOGGER.info("【MQ-IMPP_MESSAGE_QUEUE】数据接收成功：{}",msg);
             SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
             msg.setReceiverTime(sdf.format(new Date()));
@@ -73,8 +69,6 @@ public class MailQueueReceiver {
             } catch (IOException e1) {
                 e1.printStackTrace();
             }
-        } catch (InterruptedException e) {
-            e.printStackTrace();
         }
     }
 }

modules/i3plus-core-apiservice/src/main/resources/application.properties

@@ -30,6 +30,3 @@ spring.mvc.view.prefix=/upload_demo
 spring.mvc.view.suffix=.jsp
 #静态文件访问配置
 spring.resources.static-locations=/static/**,/**
-
-########## CORE-MQ ########
-spring.core.rabbitmq=false