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 02b01403..318434bc 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 @@ -257,7 +257,7 @@ public Registration registerCommandHandler(Function ack = sendSubscribe(commandName, loadFactor, outboundCommandStream.get()); subscriptionResult = CompletableFuture.allOf(subscriptionResult, ack); } @@ -285,7 +285,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 87acca6b..dd056d02 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); } - logger.info("Registered handler for query '{}' in context '{}'", queryDefinition, context); + logger.debug("Registered handler for query '{}' in context '{}'", queryDefinition, context); } } return new AsyncRegistration(subscriptionResult, () -> {