From 7ac699bc7706c85573ed3c053790dbd3e71249a9 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Wed, 6 May 2020 14:15:33 +0100 Subject: [PATCH] Dispatch sends again --- federationsender/queue/queue.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/federationsender/queue/queue.go b/federationsender/queue/queue.go index 031e9538c..1c1dc4485 100644 --- a/federationsender/queue/queue.go +++ b/federationsender/queue/queue.go @@ -89,7 +89,7 @@ func (oqs *OutgoingQueues) SendEvent( oqs.queuesMutex.Unlock() } - oq.sendEvent(ev) + go oq.sendEvent(ev) } return nil @@ -138,7 +138,7 @@ func (oqs *OutgoingQueues) SendInvite( oqs.queuesMutex.Unlock() } - oq.sendInvite(inviteReq) + go oq.sendInvite(inviteReq) return nil } @@ -182,7 +182,7 @@ func (oqs *OutgoingQueues) SendEDU( oqs.queuesMutex.Unlock() } - oq.sendEDU(e) + go oq.sendEDU(e) } return nil