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

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

@@ -41,35 +41,22 @@ public class QueueServiceImpl implements QueueService {
         if (!StringHelper.isEmpty(vo.getDedQueueName())) {
             beanDao.createQueue(vo.getDedQueueName());
         }
-
-        try {
-            // 关联死信队列、交换器、路由器
-            if (!StringHelper.isEmpty(vo.getDedQueueName(), vo.getDedExchangeName(), vo.getDedRouteKey())) {
-                beanDao.createBinding(vo.getDedExchangeName(), vo.getDedQueueName(), vo.getDedRouteKey());
-            }
-        } catch (Exception ex) {
-            // 创建死信交换器
-            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());
-            }
+        // 创建死信交换器
+        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());
-        try {
-            // 创建绑定队列
-            beanDao.createBinding(vo.getExchangeName(), vo.getQueueName(), vo.getRouteKey());
-        } catch (Exception ex) {
-            // 创建当前交换器
-            beanDao.createExchange(vo.getExchangeName());
-            // 创建绑定队列
-            beanDao.createBinding(vo.getExchangeName(), vo.getQueueName(), vo.getRouteKey());
-        }
+        // 创建当前交换器
+        beanDao.createExchange(vo.getExchangeName());
+        // 创建绑定队列
+        beanDao.createBinding(vo.getExchangeName(), vo.getQueueName(), vo.getRouteKey());
     }
 
 }