diff options
Diffstat (limited to 'synapse/replication/tcp/resource.py')
| -rw-r--r-- | synapse/replication/tcp/resource.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/synapse/replication/tcp/resource.py b/synapse/replication/tcp/resource.py index bbd2c6ec41..d421cc477f 100644 --- a/synapse/replication/tcp/resource.py +++ b/synapse/replication/tcp/resource.py @@ -74,9 +74,7 @@ class ReplicationStreamer(object): self.streams = [] # type: List[Stream] if hs.config.worker_app is None: for stream in STREAMS_MAP.values(): - if stream == FederationStream and hs.config.send_federation: - # We only support federation stream if federation sending - # hase been disabled on the master. + if stream == FederationStream: continue if stream == TypingStream: @@ -87,6 +85,9 @@ class ReplicationStreamer(object): if hs.config.server.handle_typing: self.streams.append(TypingStream(hs)) + # We always add federation stream + self.streams.append(FederationStream(hs)) + self.streams_by_name = {stream.NAME: stream for stream in self.streams} self.notifier.add_replication_callback(self.on_notifier_poke) |