summary refs log tree commit diff
path: root/synapse/replication/tcp/handler.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2020-05-27 13:35:15 +0100
committerErik Johnston <erik@matrix.org>2020-05-27 13:35:15 +0100
commit407dbf8574d676ba21ac176e62643807443b8eb6 (patch)
tree9a154bc5ac63e893d2d3a5d66170086e53562f93 /synapse/replication/tcp/handler.py
parentMerge branch 'develop' of github.com:matrix-org/synapse into matrix-org-hotfixes (diff)
parentFix up comments (diff)
downloadsynapse-407dbf8574d676ba21ac176e62643807443b8eb6.tar.xz
Merge branch 'release-v1.14.0' of github.com:matrix-org/synapse into matrix-org-hotfixes
Diffstat (limited to 'synapse/replication/tcp/handler.py')
-rw-r--r--synapse/replication/tcp/handler.py3
1 files changed, 3 insertions, 0 deletions
diff --git a/synapse/replication/tcp/handler.py b/synapse/replication/tcp/handler.py

index 03300e5336..cbcf46f3ae 100644 --- a/synapse/replication/tcp/handler.py +++ b/synapse/replication/tcp/handler.py
@@ -159,6 +159,9 @@ class ReplicationCommandHandler: 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).