diff --git a/federationsender/queue/queue.go b/federationsender/queue/queue.go index 56c81e64b..620bb2e82 100644 --- a/federationsender/queue/queue.go +++ b/federationsender/queue/queue.go @@ -167,6 +167,7 @@ func (oqs *OutgoingQueues) getQueue(destination gomatrixserverlib.ServerName) *d signing: oqs.signing, } oqs.queues[destination] = oq + oq.wakeQueueIfNeeded() } return oq }