From c2e92d0237d340fe3edc06da462b54d24c5ab7b4 Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Wed, 17 Feb 2021 13:22:09 +0000
Subject: [PATCH] Close channels

---
 federationsender/queue/queue.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/federationsender/queue/queue.go b/federationsender/queue/queue.go
index d91b36bba..8cd9e9b47 100644
--- a/federationsender/queue/queue.go
+++ b/federationsender/queue/queue.go
@@ -183,6 +183,8 @@ func (oqs *OutgoingQueues) clearQueue(destination gomatrixserverlib.ServerName)
 	case oq.backingOff.Load():
 		return
 	}
+	close(oq.notify)
+	close(oq.interruptBackoff)
 	delete(oqs.queues, destination)
 	destinationQueueTotal.Dec()
 }