Skip to content

Commit

Permalink
Ensure ReplicationStreamer is always started when replication enabled. (
Browse files Browse the repository at this point in the history
  • Loading branch information
erikjohnston authored and phil-flex committed Jun 16, 2020
1 parent 76e2124 commit 8edacc9
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 0 deletions.
1 change: 1 addition & 0 deletions changelog.d/7579.bugfix
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
Fix bug where `ReplicationStreamer` was not always started when replication was enabled. Bug introduced in v1.14.0rc1.
3 changes: 3 additions & 0 deletions synapse/replication/tcp/handler.py
Original file line number Diff line number Diff line change
Expand Up @@ -136,6 +136,9 @@ def start_replication(self, hs):
hs.config.redis_port,
)

# First let's ensure that we have a ReplicationStreamer started.
hs.get_replication_streamer()

# We need two connections to redis, one for the subscription stream and
# one to send commands to (as you can't send further redis commands to a
# connection after SUBSCRIBE is called).
Expand Down

0 comments on commit 8edacc9

Please sign in to comment.