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

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

@@ -55,7 +55,7 @@ public class MqJob extends QuartzJobBean {
             Map map = redisUtil.getHashEntries(redisKey);
             map.forEach((k, v) -> {
                 MqDto mqDto = (MqDto) v;
-                if (!mqDto.getType().name().contains(("Import".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()))) {