fixed info log for successfully unsubscribing from pubSub;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
eclipse-ditto · Sep 26, 2022 · a640f5f · a640f5f
1 parent d39bf5f
commit a640f5f
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/.../main/java/org/eclipse/ditto/internal/utils/persistence/mongo/SnapshotStreamingActor.java b/.../main/java/org/eclipse/ditto/internal/utils/persistence/mongo/SnapshotStreamingActor.java
@@ -257,7 +257,7 @@ private void serviceUnbind(final Control serviceUnbind) {
                                 getSelf()), SHUTDOWN_ASK_TIMEOUT)
                 .toCompletableFuture()
                 .thenApply(ack -> {
-                    log.info("{} unsubscribed successfully from pubsub for {} actor", ACTOR_NAME);
+                    log.info("Unsubscribed successfully from pubsub for {} actor", ACTOR_NAME);
                     return Done.getInstance();
                 });
 

diff --git a/...lipse/ditto/internal/utils/persistence/operations/AbstractPersistenceOperationsActor.java b/...lipse/ditto/internal/utils/persistence/operations/AbstractPersistenceOperationsActor.java
@@ -364,7 +364,7 @@ private void serviceUnbind(final Control serviceUnbind) {
                                                 self), SHUTDOWN_ASK_TIMEOUT)
                                 .toCompletableFuture())
                 .thenApply(ack -> {
-                    logger.info("{} unsubscribed successfully from pubsub for {} actor", getActorName());
+                    logger.info("Unsubscribed successfully from pubsub for {} actor", getActorName());
                     return Done.getInstance();
                 });
 

diff --git a/...ice/src/main/java/org/eclipse/ditto/things/service/aggregation/ThingsAggregatorActor.java b/...ice/src/main/java/org/eclipse/ditto/things/service/aggregation/ThingsAggregatorActor.java
@@ -212,7 +212,7 @@ private void serviceUnbind(final Control serviceUnbind) {
                                         SHUTDOWN_ASK_TIMEOUT)
                                 .toCompletableFuture())
                 .thenApply(ack -> {
-                    log.info("{} unsubscribed successfully from pubsub for {} actor", ACTOR_NAME);
+                    log.info("Unsubscribed successfully from pubsub for {} actor", ACTOR_NAME);
                     return Done.getInstance();
                 });