fix log statements which only mention delcared acks in ClusterMemberR…

…emovedAware which is not only used for ACKs .. Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
eclipse-ditto · Dec 1, 2021 · eb459de · eb459de
1 parent 3e57a94
commit eb459de
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...c/main/java/org/eclipse/ditto/internal/utils/pubsub/actors/ClusterMemberRemovedAware.java b/...c/main/java/org/eclipse/ditto/internal/utils/pubsub/actors/ClusterMemberRemovedAware.java
@@ -68,15 +68,15 @@ default void subscribeForClusterMemberRemovedAware() {
     default void memberRemoved(final ClusterEvent.MemberRemoved memberRemoved) {
         final var address = memberRemoved.member().address();
         if (Cluster.get(context().system()).isTerminated()) {
-            log().debug("This instance was terminated from cluster, NOT removing declared acks on removed member <{}>",
+            log().debug("This instance was terminated from cluster, NOT removing removed member address <{}>",
                     address);
         } else {
-            // acksUpdater detected unreachable remote. remove it from local ORMultiMap.
-            log().info("Removing declared acks on removed member <{}>", address);
+            // detected unreachable remote. remove it from local ORMultiMap.
+            log().info("Removing address of removed member from DData: <{}>", address);
             getDDataWriter().removeAddress(address, writeLocal())
                     .whenComplete((unused, error) -> {
                         if (error != null) {
-                            log().error(error, "Failed to remove declared acks on removed cluster member <{}>", address);
+                            log().error(error, "Failed to remove address of removed cluster member: <{}>", address);
                         }
                     });
         }