From f3d71c7a72005060e5b10c9f252d83b737510306 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Fri, 7 Aug 2020 17:18:12 +0100 Subject: [PATCH] Fix destination queue --- federationsender/queue/destinationqueue.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/federationsender/queue/destinationqueue.go b/federationsender/queue/destinationqueue.go index c4b768d6a..021444d29 100644 --- a/federationsender/queue/destinationqueue.go +++ b/federationsender/queue/destinationqueue.go @@ -262,7 +262,7 @@ func (oq *destinationQueue) backgroundSend() { // If we are backing off this server then wait for the // backoff duration to complete first, or until explicitly // told to retry. - oq.statistics.NextBackoff(oq.backingOff, oq.interruptBackoff) + oq.statistics.BackoffIfRequired(oq.backingOff, oq.interruptBackoff) // If we have pending PDUs or EDUs then construct a transaction. if pendingPDUs || pendingEDUs {