From a640f5fe0cdbd9e7a4b676dcca414f5e1af25bf9 Mon Sep 17 00:00:00 2001 From: Stefan Maute Date: Mon, 26 Sep 2022 08:49:43 +0200 Subject: [PATCH] fixed info log for successfully unsubscribing from pubSub; Signed-off-by: Stefan Maute --- .../utils/persistence/mongo/SnapshotStreamingActor.java | 2 +- .../operations/AbstractPersistenceOperationsActor.java | 2 +- .../ditto/things/service/aggregation/ThingsAggregatorActor.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/SnapshotStreamingActor.java b/internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/SnapshotStreamingActor.java index e2a13ea2d5..89e243b09e 100644 --- a/internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/mongo/SnapshotStreamingActor.java +++ b/internal/utils/persistence/src/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/internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/operations/AbstractPersistenceOperationsActor.java b/internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/operations/AbstractPersistenceOperationsActor.java index 1bbff5b3c2..321c26820c 100644 --- a/internal/utils/persistence/src/main/java/org/eclipse/ditto/internal/utils/persistence/operations/AbstractPersistenceOperationsActor.java +++ b/internal/utils/persistence/src/main/java/org/eclipse/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/things/service/src/main/java/org/eclipse/ditto/things/service/aggregation/ThingsAggregatorActor.java b/things/service/src/main/java/org/eclipse/ditto/things/service/aggregation/ThingsAggregatorActor.java index 4bea294d77..b626bef59f 100644 --- a/things/service/src/main/java/org/eclipse/ditto/things/service/aggregation/ThingsAggregatorActor.java +++ b/things/service/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(); });