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

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

@@ -37,32 +37,26 @@ public class QueueServiceImpl implements QueueService {
      */
     private void initBean(QueueVo vo) {
         vo.check();
-
-        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());
-            }
-        });
+        // 创建死信队列
+        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());
     }
 
 }