日志只执行１次

yzg-util-mq/src/main/java/com/yanzuoguang/mq/plan/YzgMqConsumer.java

@@ -11,7 +11,6 @@ import com.yanzuoguang.util.helper.JsonHelper;
 import com.yanzuoguang.util.log.Log;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.beans.factory.InitializingBean;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -21,7 +20,7 @@ import org.springframework.stereotype.Component;
  * @author 颜佐光
  */
 @Component
-public class YzgMqConsumer implements InitializingBean {
+public class YzgMqConsumer {
 
     @Autowired
     private MqService mqService;
@@ -32,21 +31,6 @@ public class YzgMqConsumer implements InitializingBean {
     @Autowired
     private QueueService queueService;
 
-    /**
-     * Invoked by a BeanFactory after it has set all bean properties supplied
-     * (and satisfied BeanFactoryAware and ApplicationContextAware).
-     * <p>This method allows the bean instance to perform initialization only
-     * possible when all bean properties have been set and to throw an
-     * exception in the event of misconfiguration.
-     *
-     * @throws Exception in the event of misconfiguration (such
-     *                   as failure to set an essential property) or if initialization fails.
-     */
-    @Override
-    public void afterPropertiesSet() throws Exception {
-        yzgMqProcedure.clearLog();
-    }
-
     /**
      * MQ回调
      *

yzg-util-mq/src/main/java/com/yanzuoguang/mq/plan/YzgMqProcedure.java

@@ -71,6 +71,7 @@ public class YzgMqProcedure implements InitializingBean {
      */
     @Override
     public void afterPropertiesSet() throws Exception {
+        System.out.println("init");
         mqService.createQueue(new QueueVo(YZG_CLEAR_LOG));
         mqService.createQueue(new QueueVo(YZG_MQ_SYSTEM_QUEUE));
         mqService.createQueue(new QueueVo(YZG_MQ_SYSTEM_QUEUE_PLAN));
@@ -95,6 +96,7 @@ public class YzgMqProcedure implements InitializingBean {
             }
             mqService.createQueue(new QueueVo(getQueueName(item), item.unit, YZG_MQ_SYSTEM_QUEUE_PLAN));
         }
+        this.clearLog();
     }
 
     /**

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java

@@ -74,6 +74,21 @@ public class MqServiceImpl implements MqService, InitializingBean {
      */
     private boolean init = false;
 
+    /**
+     * Invoked by a BeanFactory after it has set all bean properties supplied
+     * (and satisfied BeanFactoryAware and ApplicationContextAware).
+     * <p>This method allows the bean instance to perform initialization only
+     * possible when all bean properties have been set and to throw an
+     * exception in the event of misconfiguration.
+     *
+     * @throws Exception in the event of misconfiguration (such
+     *                   as failure to set an essential property) or if initialization fails.
+     */
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        this.init();
+    }
+
     public synchronized void init() {
         if (this.init) {
             return;
@@ -430,19 +445,4 @@ public class MqServiceImpl implements MqService, InitializingBean {
             return ret;
         }
     }
-
-    /**
-     * Invoked by a BeanFactory after it has set all bean properties supplied
-     * (and satisfied BeanFactoryAware and ApplicationContextAware).
-     * <p>This method allows the bean instance to perform initialization only
-     * possible when all bean properties have been set and to throw an
-     * exception in the event of misconfiguration.
-     *
-     * @throws Exception in the event of misconfiguration (such
-     *                   as failure to set an essential property) or if initialization fails.
-     */
-    @Override
-    public void afterPropertiesSet() throws Exception {
-        this.init();
-    }
 }