diff options
author | David Robertson <davidr@element.io> | 2023-02-24 11:39:06 +0000 |
---|---|---|
committer | David Robertson <davidr@element.io> | 2023-02-24 11:39:06 +0000 |
commit | 15b357e6cda2f468ec306bfb985b21e8e7943895 (patch) | |
tree | efdffa2687a8f7676be1ee283505447d20138e6b | |
parent | Changelog (diff) | |
download | synapse-15b357e6cda2f468ec306bfb985b21e8e7943895.tar.xz |
Make new replication endpoint accessible in complement
-rwxr-xr-x | docker/configure_workers_and_start.py | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/docker/configure_workers_and_start.py b/docker/configure_workers_and_start.py index 58c62f2231..3525290ed5 100755 --- a/docker/configure_workers_and_start.py +++ b/docker/configure_workers_and_start.py @@ -100,7 +100,7 @@ WORKERS_CONFIG: Dict[str, Dict[str, Any]] = { }, "federation_sender": { "app": "synapse.app.generic_worker", - "listener_resources": [], + "listener_resources": ["replication"], "endpoint_patterns": [], "shared_extra_conf": {}, "worker_extra_conf": "", @@ -345,7 +345,13 @@ def add_worker_roles_to_shared_config( shared_config.setdefault("pusher_instances", []).append(worker_name) elif worker_type == "federation_sender": + # Some outbound federation requests can be routed via federation senders, + # so federation senders need to be accessible by other workers. shared_config.setdefault("federation_sender_instances", []).append(worker_name) + instance_map[worker_name] = { + "host": "localhost", + "port": worker_port, + } elif worker_type == "event_persister": # Event persisters write to the events stream, so we need to update |