消息成功后去掉return

themis-exam/src/main/java/com/qmth/themis/exam/websocket/WebSocketMobileServer.java

@@ -291,7 +291,7 @@ public class WebSocketMobileServer implements Concurrently {
                 MqDto mqDto = JacksonUtil.readJson(new String(messageExt.getBody(), Constants.CHARSET), MqDto.class);
                 log.info(":{}-:{} websocket oe Consumer接收到的消息:{}", threadId, threadName, JacksonUtil.parseJson(mqDto));
                 mqOeLogicService.execMqOeMobileLogic(mqDto, SystemConstant.MQ_BROADCAST_TOPIC_BUFFER_LIST);
-                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+//                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
             }
         } catch (Exception e) {
             log.error("mq websocket mobile，消息消费出错", e);

themis-exam/src/main/java/com/qmth/themis/exam/websocket/WebSocketOeServer.java

@@ -284,7 +284,7 @@ public class WebSocketOeServer implements Concurrently {
                 MqDto mqDto = JacksonUtil.readJson(new String(messageExt.getBody(), Constants.CHARSET), MqDto.class);
                 log.info(":{}-:{} websocket oe Consumer接收到的消息:{}", threadId, threadName, JacksonUtil.parseJson(mqDto));
                 mqOeLogicService.execMqOeLogic(mqDto, SystemConstant.MQ_BROADCAST_TOPIC_BUFFER_LIST);
-                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+//                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
             }
         } catch (Exception e) {
             log.error("mq websocket oe，消息消费出错", e);

themis-mq/src/main/java/com/qmth/themis/mq/service/impl/MqLogicServiceImpl.java

@@ -977,7 +977,7 @@ public class MqLogicServiceImpl implements MqLogicService {
                             log.info(":{}-:{} 准备执行mq exec:{}逻辑", threadId, threadName, method.getName());
                             method.invoke(SpringContextHolder.getBean(MqLogicService.class), mqDto,
                                     SystemConstant.MQ_TOPIC_BUFFER_LIST);
-                            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+//                            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
                         } finally {
                             if (Objects.nonNull(mqDto)) {
                                 redisUtil.releaseLock(SystemConstant.REDIS_LOCK_MQ_PREFIX + mqDto.getId());
@@ -1026,7 +1026,7 @@ public class MqLogicServiceImpl implements MqLogicService {
                             log.info(":{}-:{} 准备执行mq exec:{}逻辑", threadId, threadName, method.getName());
                             method.invoke(SpringContextHolder.getBean(MqLogicService.class), mqDto,
                                     SystemConstant.MQ_DELAY_TOPIC_BUFFER_LIST);
-                            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+//                            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
                         } finally {
                             if (Objects.nonNull(mqDto)) {
                                 redisUtil.releaseLock(SystemConstant.REDIS_LOCK_MQ_PREFIX + mqDto.getId());