Construction method gix

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/consumer/TaskDispatchFailedQueueConsumer.java

@@ -47,12 +47,14 @@ public class TaskDispatchFailedQueueConsumer extends BaseDaemonThread {
     /**
      * taskPriorityQueue
      */
+    @Autowired
     @Qualifier(Constants.TASK_PRIORITY_QUEUE)
     private TaskPriorityQueue<TaskPriority> taskPriorityQueue;
 
     /**
      * taskDispatchFailedQueue
      */
+    @Autowired
     @Qualifier(Constants.TASK_DISPATCH_FAILED_QUEUE)
     private TaskPriorityQueue<TaskPriority> taskDispatchFailedQueue;
 
@@ -77,7 +79,7 @@ public class TaskDispatchFailedQueueConsumer extends BaseDaemonThread {
         }
     }
 
-    protected TaskDispatchFailedQueueConsumer(String threadName) {
+    protected TaskDispatchFailedQueueConsumer() {
         super("TaskDispatchFailedQueueConsumerThread");
     }
 

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/consumer/TaskPriorityQueueConsumer.java

@@ -73,12 +73,14 @@ public class TaskPriorityQueueConsumer extends BaseDaemonThread {
     /**
      * taskUpdateQueue
      */
+    @Autowired
     @Qualifier(Constants.TASK_PRIORITY_QUEUE)
     private TaskPriorityQueue<TaskPriority> taskPriorityQueue;
 
     /**
      * taskDispatchFailedQueue
      */
+    @Autowired
     @Qualifier(Constants.TASK_DISPATCH_FAILED_QUEUE)
     private TaskPriorityQueue<TaskPriority> taskDispatchFailedQueue;