表结构修改

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

@@ -5,7 +5,6 @@ import com.yanzuoguang.mq.service.MessageSendService;
 import com.yanzuoguang.util.helper.StringHelper;
 import com.yanzuoguang.util.thread.ThreadNext;
 import org.springframework.beans.factory.InitializingBean;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 /**
@@ -43,6 +42,9 @@ public class MessageFairResend implements ThreadNext.Next, InitializingBean {
 
     @Override
     public boolean next() throws Exception {
+        if (this.messageSendService == null) {
+            return true;
+        }
         // 另外开启线程去执行数据
         this.isPause = messageSendService.resendFair(StringHelper.getNewID(), mqConfig.getRetrySize());
         return true;