From a6e2546980fd3c80f31f391b0eefb48c497250c4 Mon Sep 17 00:00:00 2001 From: Erik Johnston Date: Tue, 5 Mar 2019 14:50:37 +0000 Subject: [PATCH] Fix outbound federation --- synapse/federation/transaction_queue.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/synapse/federation/transaction_queue.py b/synapse/federation/transaction_queue.py index cf1759f422..549bc944a6 100644 --- a/synapse/federation/transaction_queue.py +++ b/synapse/federation/transaction_queue.py @@ -406,6 +406,8 @@ class TransactionQueue(object): else: self.pending_edus_by_dest.setdefault(edu.destination, []).append(edu) + destination = edu.destination + if destination not in self.edu_tx_time_by_dest: txtime = self.clock.time() + EDU_BATCH_TIME * 1000 self.edu_tx_time_by_dest[destination] = txtime