全景看看

src/main/java/com/fdkankan/mqcontroller/service/IMqEcsService.java

@@ -15,7 +15,7 @@ import java.util.List;
  */
 public interface IMqEcsService extends IService<MqEcs> {
 
-    void add(String queueName);
+    void add(String queueName,String type);
 
     List<MqEcs> getScalingNotStopList();
 

src/main/java/com/fdkankan/mqcontroller/service/impl/MqEcsServiceImpl.java

@@ -34,9 +34,10 @@ public class MqEcsServiceImpl extends ServiceImpl<IMqEcsMapper, MqEcs> implement
     @Autowired
     RedisUtil redisUtil;
     @Override
-    public void add(String queueName) {
+    public void add(String queueName,String type) {
         MqEcs mqEcs = new MqEcs();
         mqEcs.setQueueName(queueName);
+        mqEcs.setType(type);
         this.save(mqEcs);
     }
 

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

@@ -279,7 +279,7 @@ public class TaskService {
                 }
                 Boolean flag = createEcs(take.getMqScalingConfig());
                 if(flag){
-                    mqEcsService.add(take.getQueueName());
+                    mqEcsService.add(take.getQueueName(),take.getMqScalingConfig().getType());
                     sendRabbitMq(msgList,1,mqQueueConfig.getQueueName());
                 }else {
                     openList.offer(take);