@ -61,7 +61,7 @@ public class CtrCntrlModel implements Comparable<CtrCntrlModel>{
private List<Map<String , Double>> lastHistory;
// 비정상 상황 식별 코드 (정상: true, 비정상: false)
// 비정상 상황 식별 코드 (비정상: true)
private boolean controlWarnCd;
// 비정상 상황 알림 표출 코드 (알림: true, 미알림: false)
private boolean controlWarnNotyCd;
@ -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);