🔊 Set change stream event sent log message level to trace

SoftInstigate · Feb 23, 2024 · 2ac9f52 · 2ac9f52
1 parent ecabeb1
commit 2ac9f52
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/commons/src/main/java/org/restheart/mongodb/utils/StagesInterpolator.java b/commons/src/main/java/org/restheart/mongodb/utils/StagesInterpolator.java
@@ -45,7 +45,7 @@ public enum STAGE_OPERATOR { $ifvar, $ifarg };
 
     /**
      * @param varOperator the var operator, $var for queries and aggregations, $arg for GraphQL mappings
-     * @param stageOperator the stagee operator, $ifvar for aggregations, $ifarg for GraphQL mappings
+     * @param stageOperator the stage operator, $ifvar for aggregations, $ifarg for GraphQL mappings
      * @param stages the aggregation pipeline stages
      * @param values RequestContext.getAggregationVars()
      * @return the stages, with unescaped operators and bound variables

diff --git a/mongodb/src/main/java/org/restheart/mongodb/handlers/changestreams/ChangeStreamWorker.java b/mongodb/src/main/java/org/restheart/mongodb/handlers/changestreams/ChangeStreamWorker.java
@@ -137,7 +137,7 @@ private void _changeStreamEventsLoop() {
             this.websocketSessions.stream().forEach(session -> ThreadsUtils.virtualThreadsExecutor().execute(() -> {
                 try {
                     this.send(session, msg);
-                    LOGGER.debug("Change event sent to WebSocket session {}", session.getId());
+                    LOGGER.trace("Change event sent to WebSocket session {}", session.getId());
                 } catch (Throwable t) {
                     LOGGER.error("Error sending change event to WebSocket session ", session.getId(), t);
                 }