diff --git a/federationsender/queue/destinationqueue.go b/federationsender/queue/destinationqueue.go index 237e50829..31eeaebc5 100644 --- a/federationsender/queue/destinationqueue.go +++ b/federationsender/queue/destinationqueue.go @@ -287,7 +287,7 @@ func (oq *destinationQueue) backgroundSend() { } oq.pendingPDUs = nil oq.pendingEDUs = nil - oq.pendingMutex.Lock() + oq.pendingMutex.Unlock() return } if until != nil && until.After(time.Now()) {