修改MQ请求尸体，防止出错

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

@@ -4,6 +4,7 @@ import com.yanzuoguang.mq.dao.BeanDao;
 import com.yanzuoguang.mq.service.QueueService;
 import com.yanzuoguang.mq.vo.QueueVo;
 import com.yanzuoguang.util.helper.StringHelper;
+import com.yanzuoguang.util.thread.ThreadHelper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -37,26 +38,31 @@ public class QueueServiceImpl implements QueueService {
     private void initBean(QueueVo vo) {
         vo.check();
 
-        // 创建死信队列
-        if (!StringHelper.isEmpty(vo.getDedQueueName())) {
-            beanDao.createQueue(vo.getDedQueueName());
-        }
-        // 创建死信交换器
-        if (!StringHelper.isEmpty(vo.getDedExchangeName())) {
-            beanDao.createExchange(vo.getDedExchangeName());
-        }
-        // 关联死信队列、交换器、路由器
-        if (!StringHelper.isEmpty(vo.getDedQueueName(), vo.getDedExchangeName(), vo.getDedRouteKey())) {
-            beanDao.createBinding(vo.getDedExchangeName(), vo.getDedQueueName(), vo.getDedRouteKey());
-        }
-
-
-        // 创建当前队列,并且绑定死信队列
-        beanDao.createQueue(vo.getQueueName(), vo.getDedTime(), vo.getDedExchangeName(), vo.getDedRouteKey());
-        // 创建当前交换器
-        beanDao.createExchange(vo.getExchangeName());
-        // 创建绑定队列
-        beanDao.createBinding(vo.getExchangeName(), vo.getQueueName(), vo.getRouteKey());
+        ThreadHelper.runThread(new Runnable() {
+            @Override
+            public void run() {
+                // 创建死信队列
+                if (!StringHelper.isEmpty(vo.getDedQueueName())) {
+                    beanDao.createQueue(vo.getDedQueueName());
+                }
+                // 创建死信交换器
+                if (!StringHelper.isEmpty(vo.getDedExchangeName())) {
+                    beanDao.createExchange(vo.getDedExchangeName());
+                }
+                // 关联死信队列、交换器、路由器
+                if (!StringHelper.isEmpty(vo.getDedQueueName(), vo.getDedExchangeName(), vo.getDedRouteKey())) {
+                    beanDao.createBinding(vo.getDedExchangeName(), vo.getDedQueueName(), vo.getDedRouteKey());
+                }
+
+
+                // 创建当前队列,并且绑定死信队列
+                beanDao.createQueue(vo.getQueueName(), vo.getDedTime(), vo.getDedExchangeName(), vo.getDedRouteKey());
+                // 创建当前交换器
+                beanDao.createExchange(vo.getExchangeName());
+                // 创建绑定队列
+                beanDao.createBinding(vo.getExchangeName(), vo.getQueueName(), vo.getRouteKey());
+            }
+        });
     }
 
 }