diff --git a/commons/src/main/java/org/restheart/mongodb/utils/StagesInterpolator.java b/commons/src/main/java/org/restheart/mongodb/utils/StagesInterpolator.java index 7d7bc7ea5..22eca1f12 100644 --- 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 index df698e29f..46505073f 100644 --- 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); }