diff --git a/src/main/java/com/palnet/comn/model/CtrCntrlModel.java b/src/main/java/com/palnet/comn/model/CtrCntrlModel.java index 0eac139..b7a2b2b 100644 --- a/src/main/java/com/palnet/comn/model/CtrCntrlModel.java +++ b/src/main/java/com/palnet/comn/model/CtrCntrlModel.java @@ -61,7 +61,7 @@ public class CtrCntrlModel implements Comparable{ private List> lastHistory; - // 비정상 상황 식별 코드 (정상: true, 비정상: false) + // 비정상 상황 식별 코드 (비정상: true) private boolean controlWarnCd; // 비정상 상황 알림 표출 코드 (알림: true, 미알림: false) private boolean controlWarnNotyCd; diff --git a/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java b/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java index 0049d5e..adc021f 100644 --- a/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java +++ b/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java @@ -28,7 +28,7 @@ public class MessageConsumer { } @RabbitHandler - @RabbitListener(queues = {"websocket.drone.queue"}) + @RabbitListener(queues = {"websocket.drone.queue"}, concurrency = "8") public void receiveDroneMessage(final String message) throws JsonProcessingException { // log.info("websocket message : {}", message); GPModel model = objectMapper.readValue(message, GPModel.class);