diff --git a/thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/starter/actors/SearchActor.java b/thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/starter/actors/SearchActor.java index fbfb6cf44d..1b5417e18e 100644 --- a/thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/starter/actors/SearchActor.java +++ b/thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/starter/actors/SearchActor.java @@ -524,11 +524,15 @@ private void decrementQueryCounter(final Control decrementOpCounter) { } private void serviceUnbind(final Control serviceUnbind) { - log.info("{}: unsubscribing from pubsub", serviceUnbind); + log.info("{}: unsubscribing from pubsub for {}", serviceUnbind, ACTOR_NAME); final var unsubscribe = DistPubSubAccess.unsubscribeViaGroup(ThingSearchCommand.TYPE_PREFIX, ACTOR_NAME, getSelf()); final var unsubscribeTask = - Patterns.ask(pubSubMediator, unsubscribe, SHUTDOWN_ASK_TIMEOUT).thenApply(ack -> Done.getInstance()); + Patterns.ask(pubSubMediator, unsubscribe, SHUTDOWN_ASK_TIMEOUT) + .thenApply(ack -> { + log.info("{}: unsubscribing from pubsub completed successful for {}", ack, ACTOR_NAME); + return Done.getInstance(); + }); Patterns.pipe(unsubscribeTask, getContext().getDispatcher()).to(getSender()); }