Err()...

matrix-org · Apr 8, 2024 · 43ac98d · 43ac98d
1 parent 1f72336
commit 43ac98d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/federationapi/queue/destinationqueue.go b/federationapi/queue/destinationqueue.go
@@ -295,7 +295,7 @@ func (oq *destinationQueue) checkNotificationsOnClose() {
 // backgroundSend is the worker goroutine for sending events.
 func (oq *destinationQueue) backgroundSend() {
 	// Don't try to send transactions if we are shutting down.
-	if oq.process.Context() != nil {
+	if oq.process.Context().Err() != nil {
 		return
 	}
 	// Check if a worker is already running, and if it isn't, then