소스 검색

RabbitListeners 中开启 AccessLog 的持久化

reghao 7 달 전
부모
커밋
30f791b43b
1개의 변경된 파일3개의 추가작업 그리고 3개의 파일을 삭제
  1. 3 3
      search/search-service/src/main/java/cn/reghao/tnb/search/app/log/consumer/RabbitListeners.java

+ 3 - 3
search/search-service/src/main/java/cn/reghao/tnb/search/app/log/consumer/RabbitListeners.java

@@ -22,7 +22,7 @@ import org.springframework.stereotype.Component;
 @Component
 public class RabbitListeners {
     private final LogHandler logHandler;
-    private AccessLogMongo accessLogMongo;
+    private final AccessLogMongo accessLogMongo;
 
     public RabbitListeners(LogHandler logHandler, AccessLogMongo accessLogMongo) {
         this.logHandler = logHandler;
@@ -37,9 +37,9 @@ public class RabbitListeners {
     public void accessLogConsumer(@Payload String msg) {
         GatewayLog gatewayLog = JsonConverter.jsonToObject(msg, GatewayLog.class);
         logHandler.pushGatewayLog(gatewayLog);
-        log.info("{} -> {}", gatewayLog.getRequestId(), gatewayLog.getRequestUrl());
+        //log.info("{} -> {}", gatewayLog.getRequestId(), gatewayLog.getRequestUrl());
         AccessLog accessLog = new AccessLog(gatewayLog);
-        //accessLogMongo.save(accessLog);
+        accessLogMongo.save(accessLog);
     }
 
     @RabbitListener(bindings =@QueueBinding(