only sync actors with aggregation actor for more than one client

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
eclipse-ditto · Jan 14, 2022 · bc4080f · bc4080f
1 parent 0d869f0
commit bc4080f
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/.../eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActor.java b/.../eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActor.java
@@ -1045,10 +1045,12 @@ private void startClientActorsIfRequired(final int clientCount, final DittoHeade
 
             // start client actor without name so it does not conflict with its previous incarnation
             clientActorRouter = getContext().actorOf(clusterRouterPoolProps);
-            clientActorRefsAggregationActor = getContext().actorOf(
-                    ClientActorRefsAggregationActor.props(clientCount, getSelf(), clientActorRouter,
-                            connectivityConfig.getClientConfig().getClientActorRefsNotificationDelay(),
-                            clientActorAskTimeout));
+            if (clientCount > 1) {
+                clientActorRefsAggregationActor = getContext().actorOf(
+                        ClientActorRefsAggregationActor.props(clientCount, getSelf(), clientActorRouter,
+                                connectivityConfig.getClientConfig().getClientActorRefsNotificationDelay(),
+                                clientActorAskTimeout));
+            }
             updateLoggingIfEnabled();
         } else if (clientActorRouter != null) {
             log.debug("ClientActor already started.");