diff --git a/src/main/java/com/palnet/biz/api/ctr/cntrl/service/CtrCntrlService.java b/src/main/java/com/palnet/biz/api/ctr/cntrl/service/CtrCntrlService.java index 26d166d..c1b5f19 100644 --- a/src/main/java/com/palnet/biz/api/ctr/cntrl/service/CtrCntrlService.java +++ b/src/main/java/com/palnet/biz/api/ctr/cntrl/service/CtrCntrlService.java @@ -283,6 +283,7 @@ public class CtrCntrlService { model.setCreateUserId(warnLog.getCreateUserId()); } + if(control.getCntrlId()!=null) return result; model.setCntrlId(control.getCntrlId()); model.setIdntfNum(control.getIdntfNum()); model.setWarnCount(warnCount); diff --git a/src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java b/src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java index 8aae6f6..b6dfc5f 100644 --- a/src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java +++ b/src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java @@ -33,7 +33,7 @@ public class MessageConsumer { GPModel model = objectMapper.readValue(message, GPModel.class); messageService.insert(model); // GPS 정보 DB 동기화 처리 - channel.queueDeclare(message, true, false, false, null); +// channel.queueDeclare(message, true, false, false, null); channel.basicAck(tag, false); } catch (RuntimeException e) { channel.basicReject(tag, false);