From 71abbf1719fdf32bad5233a08677278c9fe328e2 Mon Sep 17 00:00:00 2001
From: asahtik <asahtik@gmail.com>
Date: Thu, 2 Jul 2026 14:44:58 +0200
Subject: [PATCH] Only send to opened queues

---
 src/pipeline/Node.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/pipeline/Node.cpp b/src/pipeline/Node.cpp
index d57db74071..5f960f239f 100644
--- a/src/pipeline/Node.cpp
+++ b/src/pipeline/Node.cpp
@@ -246,7 +246,7 @@ void Node::Output::send(const std::shared_ptr<ADatatype>& msg) {
     // }
     auto sendToInputs = [this, &msg]() {
         for(auto& messageQueue : connectedInputs) {
-            messageQueue->send(msg);
+            if(!messageQueue->isClosed()) messageQueue->send(msg);
         }
     };
     if(pipelineEventDispatcher && pipelineEventDispatcher->sendEvents) {