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 917015f..27efdb9 100644 --- a/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java +++ b/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java @@ -28,8 +28,9 @@ public class MessageConsumer { } @RabbitHandler - @RabbitListener(queues = {"websocket.drone.queue"}) + @RabbitListener(queues = {"websocket.drone.queue"}, concurrency = "8") public void receiveDroneMessage(final String message) throws JsonProcessingException { + GPModel model = objectMapper.readValue(message, GPModel.class); CtrCntrlModel history = this.modelConvert(model); diff --git a/src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java b/src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java index e624e6e..d33c5f8 100644 --- a/src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java +++ b/src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java @@ -21,8 +21,8 @@ public class GpHistoryScheduler { this.gpHistoryShareContext = gpHistoryShareContext; } - /* Client 노출 시간 Test 10초 */ - @Scheduled(fixedDelay = 1000 * 10) + /* Client 노출 시간 5분 */ + @Scheduled(fixedDelay = 10000 * 5) public void removeHistory() { Map allHistory = gpHistoryShareContext.getAllHistory();