升级新版本

yzg-util-mq/src/main/java/com/yanzuoguang/mq/dao/impl/MessageDaoImpl.java

@@ -6,6 +6,7 @@ import com.yanzuoguang.dao.impl.SqlData;
 import com.yanzuoguang.mq.dao.MessageDao;
 import com.yanzuoguang.mq.vo.MessageVo;
 import com.yanzuoguang.util.helper.YzgTimeout;
+import com.yanzuoguang.util.thread.ThreadHelper;
 import com.yanzuoguang.util.vo.MapRow;
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.stereotype.Component;

yzg-util-mq/src/main/java/com/yanzuoguang/mq/dao/impl/MessageLogDaoImpl.java

@@ -3,6 +3,8 @@ package com.yanzuoguang.mq.dao.impl;
 import com.yanzuoguang.dao.impl.BaseDaoImpl;
 import com.yanzuoguang.mq.dao.MessageLogDao;
 import com.yanzuoguang.mq.vo.MessageLogVo;
+import com.yanzuoguang.util.helper.YzgTimeout;
+import com.yanzuoguang.util.thread.ThreadHelper;
 import com.yanzuoguang.util.vo.MapRow;
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.stereotype.Component;

yzg-util-mq/src/main/java/com/yanzuoguang/mq/dao/impl/QueueServerDaoImpl.java

@@ -4,6 +4,8 @@ import com.yanzuoguang.dao.impl.BaseDaoImpl;
 import com.yanzuoguang.db.DbExecute;
 import com.yanzuoguang.mq.dao.QueueServerDao;
 import com.yanzuoguang.mq.vo.QueueServerVo;
+import com.yanzuoguang.util.helper.YzgTimeout;
+import com.yanzuoguang.util.thread.ThreadHelper;
 import com.yanzuoguang.util.vo.MapRow;
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.stereotype.Component;

yzg-util-mq/src/main/java/com/yanzuoguang/mq/dao/impl/QueueServerTokenDaoImpl.java

@@ -3,6 +3,8 @@ package com.yanzuoguang.mq.dao.impl;
 import com.yanzuoguang.dao.impl.BaseDaoImpl;
 import com.yanzuoguang.mq.dao.QueueServerTokenDao;
 import com.yanzuoguang.mq.vo.QueueServerTokenVo;
+import com.yanzuoguang.util.helper.YzgTimeout;
+import com.yanzuoguang.util.thread.ThreadHelper;
 import com.yanzuoguang.util.vo.MapRow;
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.stereotype.Component;