File tree Expand file tree Collapse file tree 1 file changed +15
-0
lines changed
Expand file tree Collapse file tree 1 file changed +15
-0
lines changed Original file line number Diff line number Diff line change 322322 "shared_extra_conf" : {},
323323 "worker_extra_conf" : "" ,
324324 },
325+ "thread_subscriptions" : {
326+ "app" : "synapse.app.generic_worker" ,
327+ "listener_resources" : ["client" , "replication" ],
328+ "endpoint_patterns" : [
329+ "^/_matrix/client/unstable/io.element.msc4306.thread_subscriptions/.*" ,
330+ ],
331+ "shared_extra_conf" : {},
332+ "worker_extra_conf" : "" ,
333+ },
325334}
326335
327336# Templates for sections that may be inserted multiple times in config files
@@ -431,6 +440,12 @@ def add_worker_roles_to_shared_config(
431440 if "federation_sender" in worker_types_set :
432441 shared_config .setdefault ("federation_sender_instances" , []).append (worker_name )
433442
443+ if "thread_subscriptions" in worker_types_set :
444+ # we can have multiple instances of thread_subscriptions workers
445+ shared_config .setdefault ("stream_writers" , {}).setdefault (
446+ "thread_subscriptions" , []
447+ ).append (worker_name )
448+
434449 if "event_persister" in worker_types_set :
435450 # Event persisters write to the events stream, so we need to update
436451 # the list of event stream writers
You can’t perform that action at this time.
0 commit comments