修改消息路由

gic-platform-operation-web/src/main/java/com/gic/operation/web/controller/MQController.java

@@ -2,6 +2,7 @@ package com.gic.operation.web.controller;
 
 import com.gic.commons.webapi.reponse.RestResponse;
 import com.gic.enterprise.error.ErrorCode;
+import com.gic.mq.sdk.MQConstant;
 import com.gic.mq.sdk.entity.*;
 import com.gic.mq.sdk.entity.response.AddRouterResponse;
 import com.gic.mq.sdk.entity.response.DeleteRouterResponse;
@@ -120,7 +121,7 @@ public class MQController {
         if (!updateResponse2.isSuccess()) {
             return RestResponse.failure(ErrorCode.SYSTEM_ERROR.getCode(), updateResponse2.getMessage());
         }
-        UpdateResponse updateResponse3 = mqConfigService.stopReadingMessage(0 == readingMessageStopped);
+        UpdateResponse updateResponse3 = mqConfigService.stopReadingMessage(1 == readingMessageStopped);
         if (!updateResponse3.isSuccess()) {
             return RestResponse.failure(ErrorCode.SYSTEM_ERROR.getCode(), updateResponse3.getMessage());
         }