导入导出推送拉取数据不循环

themis-task/src/main/java/com/qmth/themis/task/quartz/MqJob.java

@@ -55,10 +55,10 @@ public class MqJob extends QuartzJobBean {
             Map map = redisUtil.getHashEntries(redisKey);
             map.forEach((k, v) -> {
                 MqDto mqDto = (MqDto) v;
-                if (Objects.nonNull(mqDto.getType()) && !mqDto.getType().name().contains(("Import".toUpperCase()))
-                        && !mqDto.getType().name().contains(("Export".toUpperCase()))
-                        && !mqDto.getType().name().contains(("Push".toUpperCase()))
-                        && !mqDto.getType().name().contains(("Sync".toUpperCase()))) {
+//                if (Objects.nonNull(mqDto.getType()) && !mqDto.getType().name().contains(("Import".toUpperCase()))
+//                        && !mqDto.getType().name().contains(("Export".toUpperCase()))
+//                        && !mqDto.getType().name().contains(("Push".toUpperCase()))
+//                        && !mqDto.getType().name().contains(("Sync".toUpperCase()))) {
                     if (mqDto.getReconsume() >= SystemConstant.MAXRECONSUMETIMES) {
                         tmRocketMessageService.saveMqMessageError(mqDto, redisKey);
                     } else {
@@ -66,7 +66,7 @@ public class MqJob extends QuartzJobBean {
                         redisUtil.set(redisKey, mqDto.getId(), mqDto);
                         producerServer.sendOneWay(mqDto);
                     }
-                }
+//                }
             });
         }
     }