From bc4080f9091e32002f0343c1b134df19238e6aac Mon Sep 17 00:00:00 2001 From: Johannes Schneider Date: Fri, 14 Jan 2022 13:21:54 +0100 Subject: [PATCH] only sync actors with aggregation actor for more than one client Signed-off-by: Johannes Schneider --- .../persistence/ConnectionPersistenceActor.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActor.java b/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActor.java index 48071398d8..610ac533db 100644 --- a/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/persistence/ConnectionPersistenceActor.java +++ b/connectivity/service/src/main/java/org/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.");