diff --git a/src/main/java/io/axoniq/axonserver/connector/command/impl/CommandChannelImpl.java b/src/main/java/io/axoniq/axonserver/connector/command/impl/CommandChannelImpl.java index fb361b7e..4a5633c0 100644 --- a/src/main/java/io/axoniq/axonserver/connector/command/impl/CommandChannelImpl.java +++ b/src/main/java/io/axoniq/axonserver/connector/command/impl/CommandChannelImpl.java @@ -260,7 +260,7 @@ public Registration registerCommandHandler(Function ack = sendSubscribe(commandName, loadFactor, outboundCommandStream.get()); subscriptionResult = CompletableFuture.allOf(subscriptionResult, ack).whenComplete((r,e) -> { if (e == null) { - logger.info("Registered handler for command '{}' in context '{}'", commandName, context); + logger.debug("Registered handler for command '{}' in context '{}'", commandName, context); } else { logger.warn("An error occurred while registering command '{}' in context '{}'", commandName, context, e); } @@ -290,7 +290,7 @@ private CompletableFuture unsubscribe(CommandHandler handler, CompletableFuture future = CompletableFuture.completedFuture(null); for (String commandName : commandNames) { if (commandHandlers.get(commandName) == handler) { - logger.info("Deregistered handler for command '{}' in context '{}'", commandName, context); + logger.debug("Deregistered handler for command '{}' in context '{}'", commandName, context); CompletableFuture result = sendUnsubscribe(commandName, outboundCommandStream.get()) .thenRun(() -> commandHandlers.remove(commandName, handler)); future = CompletableFuture.allOf(future, result); diff --git a/src/main/java/io/axoniq/axonserver/connector/query/impl/QueryChannelImpl.java b/src/main/java/io/axoniq/axonserver/connector/query/impl/QueryChannelImpl.java index 0d417b99..38e460d0 100644 --- a/src/main/java/io/axoniq/axonserver/connector/query/impl/QueryChannelImpl.java +++ b/src/main/java/io/axoniq/axonserver/connector/query/impl/QueryChannelImpl.java @@ -319,7 +319,7 @@ public Registration registerQueryHandler(QueryHandler handler, QueryDefinition.. outboundQueryStream.get()); subscriptionResult = CompletableFuture.allOf(subscriptionResult, instructionResult).whenComplete((r,e) -> { if (e == null) { - logger.info("Registered handler for query '{}' in context '{}'", queryDefinition.getQueryName(), context); + logger.debug("Registered handler for query '{}' in context '{}'", queryDefinition.getQueryName(), context); } else { logger.warn("An error occurred while registering query '{}' in context '{}'", queryDefinition.getQueryName(), context, e); }