Merge pull request #89 from FinalDoubleTen/BE-66-Refactor-STOMP

Refactor : 경로 계산 로그 추가 + heartbeat 값 수정
WePlanPlans · Jan 18, 2024 · 42fd0d7 · 42fd0d7
2 parents cd04efd + efc2539
commit 42fd0d7
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/main/java/org/tenten/tentenstomp/config/WebSocketConfig.java b/src/main/java/org/tenten/tentenstomp/config/WebSocketConfig.java
@@ -28,7 +28,8 @@ public void registerStompEndpoints(StompEndpointRegistry endpointRegistry) {
     @Override
     public void configureMessageBroker(MessageBrokerRegistry brokerRegistry) {
         brokerRegistry.setApplicationDestinationPrefixes("/pub");
-        brokerRegistry.enableSimpleBroker("/sub");
+        brokerRegistry.enableSimpleBroker("/sub").setHeartbeatValue(new long[]{1000, 2000});
+
     }
 
     @Override

diff --git a/src/main/java/org/tenten/tentenstomp/global/component/AsyncPathComponent.java b/src/main/java/org/tenten/tentenstomp/global/component/AsyncPathComponent.java
@@ -29,7 +29,7 @@ public void calculatePath(TripPlace fromPlace, TripPlace toPlace, List<TripPathI
         } else {
             pathInfo = odsayComponent.calculatePathInfo(fromPlace.longitude(), fromPlace.latitude(), toPlace.longitude(), toPlace.latitude());
         }
-        log.info("from " + fromPlace.seqNum() + " to " + toPlace.seqNum() + " executionTime : " + ((System.currentTimeMillis() - startTime) / 1000.0));
+        log.info("from id "+fromPlace.tripItemId()+" to id "+toPlace.tripItemId()+" from seqNum " + fromPlace.seqNum() + " to seqNum " + toPlace.seqNum() + " executionTime : " + ((System.currentTimeMillis() - startTime) / 1000.0));
         pathInfoMsgs.add(new TripPathInfoMsg(fromPlace.tripItemId(), toPlace.tripItemId(), fromPlace.seqNum(), toPlace.seqNum(), fromPlace.longitude(), fromPlace.latitude(), toPlace.longitude(), toPlace.latitude(),  pathInfo));
     }
 }