diff --git a/federationsender/queue/destinationqueue.go b/federationsender/queue/destinationqueue.go index ab779a5d3..accd39f4d 100644 --- a/federationsender/queue/destinationqueue.go +++ b/federationsender/queue/destinationqueue.go @@ -250,6 +250,8 @@ func (oq *destinationQueue) backgroundSend() { oq.statistics.Success() // Clean up the in-memory buffers. oq.cleanPendingEDUs() + } else { + break } }