全景看看

src/main/java/com/fdkankan/mqcontroller/task/TaskService.java

@@ -112,7 +112,7 @@ public class TaskService {
             configLogsMap.put(config.getId(),msgList);
         }
         //是否需要重新组合队列
-        allocateQueue2(queueConfigList,mqSendLogs,type);
+        allocateQueue2(queueConfigList,mqSendLogs);
 
         for (MqQueueConfig mqQueueConfig : queueConfigList) {
             List<MqSendLog> msgList = configLogsMap.get(mqQueueConfig.getId());
@@ -144,7 +144,7 @@ public class TaskService {
      * 设置调配队列计算
      * 调配A，B，C
      */
-    private void allocateQueue2(List<MqQueueConfig> queueConfigList,List<MqSendLog> mqSendLogs,String type){
+    private void allocateQueue2(List<MqQueueConfig> queueConfigList,List<MqSendLog> mqSendLogs){
         //获取常驻队列
         for (MqQueueConfig residentConfig : queueConfigList) { // A ,B ,C
             if(residentConfig.getIsSpecial() == 1){