diff options
| author | Erik Johnston <erikj@matrix.org> | 2023-09-04 17:14:09 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-09-04 17:14:09 +0100 |
| commit | d35bed8369514fe727b4fe1afb68f48cc8b2655a (patch) | |
| tree | 7343ece3b82ac87a594865c4074623b45b0297b4 /synapse/handlers/devicemessage.py | |
| parent | Add last_seen_ts to the admin users API (#16218) (diff) | |
| download | synapse-d35bed8369514fe727b4fe1afb68f48cc8b2655a.tar.xz | |
Don't wake up destination transaction queue if they're not due for retry. (#16223)
Diffstat (limited to 'synapse/handlers/devicemessage.py')
| -rw-r--r-- | synapse/handlers/devicemessage.py | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/synapse/handlers/devicemessage.py b/synapse/handlers/devicemessage.py index 798c7039f9..1c79f7a61e 100644 --- a/synapse/handlers/devicemessage.py +++ b/synapse/handlers/devicemessage.py @@ -302,10 +302,9 @@ class DeviceMessageHandler: ) if self.federation_sender: - for destination in remote_messages.keys(): - # Enqueue a new federation transaction to send the new - # device messages to each remote destination. - self.federation_sender.send_device_messages(destination) + # Enqueue a new federation transaction to send the new + # device messages to each remote destination. + await self.federation_sender.send_device_messages(remote_messages.keys()) async def get_events_for_dehydrated_device( self, |