Wake queue when created, otherwise cleanup doesn't get called in all cases

This commit is contained in:
Neil Alexander 2021-02-17 13:56:13 +00:00
parent 9ec3886f65
commit 8cbba695e1
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944

View file

@ -167,6 +167,7 @@ func (oqs *OutgoingQueues) getQueue(destination gomatrixserverlib.ServerName) *d
signing: oqs.signing,
}
oqs.queues[destination] = oq
oq.wakeQueueIfNeeded()
}
return oq
}