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 48b4a76..bceeff8 100644 --- a/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java +++ b/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java @@ -30,7 +30,7 @@ public class MessageConsumer { @RabbitHandler @RabbitListener(queues = {"websocket.drone.queue"}) public void receiveDroneMessage(final String message) throws JsonProcessingException { - log.info("websocket message : {}", message); + log.debug("websocket message : {}", message); GPModel model = objectMapper.readValue(message, GPModel.class); diff --git a/src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java b/src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java index f01f2b4..151ac77 100644 --- a/src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java +++ b/src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java @@ -14,7 +14,7 @@ import java.util.Objects; @Component public class GpHistoryScheduler { - private final int timeLimit = 300; // 5분 + private final int timeLimit = 10; // -- 테스트 10초 private final GPHistoryShareContext gpHistoryShareContext; public GpHistoryScheduler(GPHistoryShareContext gpHistoryShareContext) { @@ -22,7 +22,7 @@ public class GpHistoryScheduler { } /* Client 노출 시간 5분 */ - @Scheduled(fixedDelay = 1000 * 60 * 5) + @Scheduled(fixedDelay = 1000 * 10) public void removeHistory() { Map allHistory = gpHistoryShareContext.getAllHistory(); diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index e3e4955..c935828 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -7,10 +7,6 @@ spring: port: 5672 username: guest password: guest - listener: - simple: - max-concurrency: 8 - concurrency: 4 server: port: 8181