diff options
author | Patrick Cloke <clokep@users.noreply.github.com> | 2022-03-10 08:01:56 -0500 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-03-10 13:01:56 +0000 |
commit | 3e4af36bc8515504721b3c1b1d64d4f45359bf88 (patch) | |
tree | e39ad5a0a4196056cce920ac906b39ed7417e501 /synapse/handlers/presence.py | |
parent | Remove dead code in `tests/storage/test_database.py` (#12197) (diff) | |
download | synapse-3e4af36bc8515504721b3c1b1d64d4f45359bf88.tar.xz |
Rename get_tcp_replication to get_replication_command_handler. (#12192)
Since the object it returns is a ReplicationCommandHandler. This is clean-up from adding support to Redis where the command handler was added as an additional layer of abstraction from the TCP protocol.
Diffstat (limited to 'synapse/handlers/presence.py')
-rw-r--r-- | synapse/handlers/presence.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/handlers/presence.py b/synapse/handlers/presence.py index c155098bee..9927a30e6e 100644 --- a/synapse/handlers/presence.py +++ b/synapse/handlers/presence.py @@ -424,13 +424,13 @@ class WorkerPresenceHandler(BasePresenceHandler): async def _on_shutdown(self) -> None: if self._presence_enabled: - self.hs.get_tcp_replication().send_command( + self.hs.get_replication_command_handler().send_command( ClearUserSyncsCommand(self.instance_id) ) def send_user_sync(self, user_id: str, is_syncing: bool, last_sync_ms: int) -> None: if self._presence_enabled: - self.hs.get_tcp_replication().send_user_sync( + self.hs.get_replication_command_handler().send_user_sync( self.instance_id, user_id, is_syncing, last_sync_ms ) |