From d06c320a21d0efeebb682583a18764d05603b828 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?scnoh=28=EB=85=B8=EC=8A=B9=EC=B2=A0=29?= Date: Wed, 10 Aug 2022 16:28:50 +0900 Subject: [PATCH] =?UTF-8?q?message=20consumer=20=EC=A6=9D=EA=B0=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/palnet/process/message/consumer/MessageConsumer.java | 3 ++- .../java/com/palnet/process/scheduler/GpHistoryScheduler.java | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) 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();