SQL层级处理的支持

yzg-util-mq/src/main/java/com/yanzuoguang/mq/vo/QueueVo.java

@@ -9,6 +9,7 @@ import com.yanzuoguang.util.vo.InitDao;
 
 /**
  * 创建队列
+ *
  * @author 颜佐光
  */
 @TableAnnotation("Queue_Queue")
@@ -76,7 +77,7 @@ public class QueueVo extends BaseVo implements InitDao {
                 || !StringHelper.isEmpty(this.getDedQueueName())
                 || !StringHelper.isEmpty(this.getDedExchangeName())
                 || !StringHelper.isEmpty(this.getDedRouteKey())
-                ) {
+        ) {
             check.notBlankCheck("DelayQueueName", this.getDedQueueName())
                     .notBlankCheck("DelayExchangeName", this.getDedExchangeName())
                     .notBlankCheck("DelayRouteKey", this.getDedRouteKey())
@@ -87,7 +88,7 @@ public class QueueVo extends BaseVo implements InitDao {
     /**
      * 构造函数
      */
-    public QueueVo(){
+    public QueueVo() {
     }
 
     /**
@@ -104,6 +105,18 @@ public class QueueVo extends BaseVo implements InitDao {
         this.routeKey = routeKey;
     }
 
+    /**
+     * 构造函数，用于创建延迟队列。</p>
+     * 会创建queueName、exchangeName并且通过routeKey绑定。
+     *
+     * @param queueName 队列名称,交换器名称,路由键
+     */
+    public QueueVo(String queueName) {
+        this.queueName = queueName;
+        this.exchangeName = queueName;
+        this.routeKey = queueName;
+    }
+
     /**
      * 构造函数，用于创建延迟队列。</p>
      * 创建 queueName、exchangeName 并且通过 routeKey 绑定, 创建 dedQueueName、dedExchangeName 并且通过 dedRouteKey 绑定,
@@ -127,6 +140,26 @@ public class QueueVo extends BaseVo implements InitDao {
         this.dedRouteKey = dedRouteKey;
     }
 
+
+    /**
+     * 构造函数，用于创建延迟队列。</p>
+     * 创建 queueName、exchangeName 并且通过 routeKey 绑定, 创建 dedQueueName、dedExchangeName 并且通过 dedRouteKey 绑定,
+     * 将 queueName 的死信队列设置为 dedExchangeName 和 dedRouteKey .
+     *
+     * @param queueName    队列名称,路由键,交换器名称
+     * @param dedTime      死信时间
+     * @param dedQueueName 死信交换器名称,死信交换队列名称,死信路由键
+     */
+    public QueueVo(String queueName, long dedTime, String dedQueueName) {
+        this.queueName = queueName;
+        this.exchangeName = queueName;
+        this.routeKey = queueName;
+        this.dedTime = dedTime;
+        this.dedExchangeName = dedQueueName;
+        this.dedQueueName = dedQueueName;
+        this.dedRouteKey = dedQueueName;
+    }
+
     public String getQueueId() {
         return queueId;
     }