diff options
| author | Erik Johnston <erik@matrix.org> | 2020-07-16 14:06:28 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-07-16 14:06:28 +0100 |
| commit | 649a7ead5c4bd2d8b7c486ac1a68ce4e41d49767 (patch) | |
| tree | 2a3ee5836578e99c15a8c342934c6e7d056563a2 /synapse/federation/sender/per_destination_queue.py | |
| parent | Merge pull request #7866 from matrix-org/rav/fix_guest_user_id (diff) | |
| download | synapse-649a7ead5c4bd2d8b7c486ac1a68ce4e41d49767.tar.xz | |
Add ability to run multiple pusher instances (#7855)
This reuses the same scheme as federation sender sharding
Diffstat (limited to 'synapse/federation/sender/per_destination_queue.py')
| -rw-r--r-- | synapse/federation/sender/per_destination_queue.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/federation/sender/per_destination_queue.py b/synapse/federation/sender/per_destination_queue.py index 6402136e8a..3436741783 100644 --- a/synapse/federation/sender/per_destination_queue.py +++ b/synapse/federation/sender/per_destination_queue.py @@ -78,7 +78,7 @@ class PerDestinationQueue(object): self._federation_shard_config = hs.config.federation.federation_shard_config self._should_send_on_this_instance = True - if not self._federation_shard_config.should_send_to( + if not self._federation_shard_config.should_handle( self._instance_name, destination ): # We don't raise an exception here to avoid taking out any other |