Skip to content

Commit d3fc5b3

Browse files
committed
update existing clients
1 parent 1504ec7 commit d3fc5b3

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

fabric_cf/actor/core/container/remote_actor_cache.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -232,7 +232,10 @@ def establish_peer_private(self, *, mgmt_actor: ABCMgmtActor, peer_guid: ID, upd
232232
client.set_name(name=cache_entry.get(self.actor_name))
233233
client.set_guid(guid=str(peer_guid))
234234
try:
235-
mgmt_actor.register_client(client=client, kafka_topic=kafka_topic)
235+
if not update:
236+
mgmt_actor.register_client(client=client, kafka_topic=kafka_topic)
237+
else:
238+
mgmt_actor.update_client(client=client, kafka_topic=kafka_topic)
236239
except Exception as e:
237240
raise RemoteActorCacheException(f"Could not register actor: {peer_guid} as a client of "
238241
f"actor: {mgmt_actor} e= {e}")

0 commit comments

Comments
 (0)