박재우 2 years ago
parent
commit
a9c18d10e3
  1. 1
      src/main/java/com/palnet/biz/api/ctr/cntrl/service/CtrCntrlService.java
  2. 2
      src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java

1
src/main/java/com/palnet/biz/api/ctr/cntrl/service/CtrCntrlService.java

@ -283,6 +283,7 @@ public class CtrCntrlService {
model.setCreateUserId(warnLog.getCreateUserId()); model.setCreateUserId(warnLog.getCreateUserId());
} }
if(control.getCntrlId()!=null) return result;
model.setCntrlId(control.getCntrlId()); model.setCntrlId(control.getCntrlId());
model.setIdntfNum(control.getIdntfNum()); model.setIdntfNum(control.getIdntfNum());
model.setWarnCount(warnCount); model.setWarnCount(warnCount);

2
src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java

@ -33,7 +33,7 @@ public class MessageConsumer {
GPModel model = objectMapper.readValue(message, GPModel.class); GPModel model = objectMapper.readValue(message, GPModel.class);
messageService.insert(model); // GPS 정보 DB 동기화 처리 messageService.insert(model); // GPS 정보 DB 동기화 처리
channel.queueDeclare(message, true, false, false, null); // channel.queueDeclare(message, true, false, false, null);
channel.basicAck(tag, false); channel.basicAck(tag, false);
} catch (RuntimeException e) { } catch (RuntimeException e) {
channel.basicReject(tag, false); channel.basicReject(tag, false);

Loading…
Cancel
Save