message 설정 변경

src/main/java/com/palnet/process/message/Receiver.java

@@ -0,0 +1,22 @@
+package com.palnet.process.message;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.CountDownLatch;
+
+@Component
+@Slf4j
+public class Receiver {
+
+    private CountDownLatch latch = new CountDownLatch(1);
+
+    public void receiveMessage(String message) {
+        log.info("Received <" + message);
+        latch.countDown();
+    }
+
+    public CountDownLatch getLatch() {
+        return latch;
+    }
+}

src/main/java/com/palnet/process/message/consumer/MessageConsumer.java

@@ -30,8 +30,7 @@ public class MessageConsumer {
     @RabbitHandler
     @RabbitListener(queues = {"websocket.drone.queue"})
     public void receiveDroneMessage(final String message) throws JsonProcessingException {
-		log.debug("websocket message : {}", message);
-
+//		log.info("websocket message : {}", message);
 		GPModel model = objectMapper.readValue(message, GPModel.class);
 
 		CtrCntrlModel history = this.modelConvert(model); // 웹 표출 model로 변환

src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java

@@ -14,14 +14,13 @@ import java.util.Objects;
 @Component
 public class GpHistoryScheduler {
 
-    private final int timeLimit = 10; // -- 테스트 10초
+    private final int timeLimit = 60; // -- 화면 노출시간 1분
     private final GPHistoryShareContext gpHistoryShareContext;
 
     public GpHistoryScheduler(GPHistoryShareContext gpHistoryShareContext) {
         this.gpHistoryShareContext = gpHistoryShareContext;
     }
 
-    /* Client 노출 시간 5분  */
     @Scheduled(fixedDelay = 1000 * 10)
     public void removeHistory() {
         Map<String, CtrCntrlModel> allHistory = gpHistoryShareContext.getAllHistory();

src/main/resources/application.yml

@@ -7,6 +7,7 @@ spring:
     port: 5672
     username: guest
     password: guest
+    virtual-host: /
 
 server:
   port: 8181