|
@@ -55,12 +55,17 @@ public class MqJob extends QuartzJobBean {
|
|
Map map = redisUtil.getHashEntries(redisKey);
|
|
Map map = redisUtil.getHashEntries(redisKey);
|
|
map.forEach((k, v) -> {
|
|
map.forEach((k, v) -> {
|
|
MqDto mqDto = (MqDto) v;
|
|
MqDto mqDto = (MqDto) v;
|
|
- if (mqDto.getReconsume() >= SystemConstant.MAXRECONSUMETIMES) {
|
|
|
|
- tmRocketMessageService.saveMqMessageError(mqDto, redisKey);
|
|
|
|
- } else {
|
|
|
|
- mqDto.setReconsume(mqDto.getReconsume() + 1);
|
|
|
|
- redisUtil.set(redisKey, mqDto.getId(), mqDto);
|
|
|
|
- producerServer.sendOneWay(mqDto);
|
|
|
|
|
|
+ if (!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 {
|
|
|
|
+ mqDto.setReconsume(mqDto.getReconsume() + 1);
|
|
|
|
+ redisUtil.set(redisKey, mqDto.getId(), mqDto);
|
|
|
|
+ producerServer.sendOneWay(mqDto);
|
|
|
|
+ }
|
|
}
|
|
}
|
|
});
|
|
});
|
|
}
|
|
}
|