自动变量处理

yzg-util-mq/src/main/java/com/yanzuoguang/mq/plan/MessageInitPlan.java → yzg-util-mq/src/main/java/com/yanzuoguang/mq/plan/MqMessageInitPlan.java

@@ -16,7 +16,7 @@ import java.util.List;
  * 消息队列初始化服务，用于重启时，初始化消息队列对象
  */
 @Component
-public class MessageInitPlan implements ThreadNext.Next, Runnable {
+public class MqMessageInitPlan implements ThreadNext.Next, Runnable {
 
     @Autowired
     private MessageService messageService;
@@ -27,7 +27,7 @@ public class MessageInitPlan implements ThreadNext.Next, Runnable {
     @Value("${yzg.mq.retry.time:60000}")
     private int retryTime;
 
-    public MessageInitPlan() {
+    public MqMessageInitPlan() {
         ThreadNext.start(this, "message init error");
     }
 
@@ -64,7 +64,7 @@ public class MessageInitPlan implements ThreadNext.Next, Runnable {
             try {
                 messageService.nextSend(message);
             } catch (Exception ex) {
-                Log.error(MessageInitPlan.class, ex);
+                Log.error(MqMessageInitPlan.class, ex);
             }
         }
     }

yzg-util-mq/src/main/java/com/yanzuoguang/mq/plan/QueueInitPlan.java → yzg-util-mq/src/main/java/com/yanzuoguang/mq/plan/MqQueueInitPlan.java

@@ -9,12 +9,12 @@ import org.springframework.stereotype.Component;
  * 消息队列初始化服务，用于重启时，初始化消息队列对象
  */
 @Component
-public class QueueInitPlan implements ThreadNext.Next {
+public class MqQueueInitPlan implements ThreadNext.Next {
 
     @Autowired
     private QueueService queueService;
 
-    public QueueInitPlan() {
+    public MqQueueInitPlan() {
         ThreadNext.start(this, "queue init error");
     }