From c2de980cbef0f9a1710a092249a9446ca80605e2 Mon Sep 17 00:00:00 2001
From: ooing <335008594@qq.com>
Date: Fri, 12 Dec 2025 09:32:53 +0800
Subject: [PATCH] Add enable check for consumer before processing

---
 src/Process/Consumer.php | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/src/Process/Consumer.php b/src/Process/Consumer.php
index e99062a..7051efd 100644
--- a/src/Process/Consumer.php
+++ b/src/Process/Consumer.php
@@ -71,6 +71,16 @@ public function onWorkerStart()
                         echo "Consumer {$class} queue not exists\r\n";
                         continue;
                     }
+                    
+                    
+                    $enable   = $consumer->enable??true;
+                    if (!$enable) {
+                        echo "Consumer {$class} is disabled\r\n";
+                        continue;
+                    }
+                    
+
+                    
                     $this->_consumers[$queue] = $consumer;
                     $connection = Client::connection($connection_name);
                     $consumer_func = function ($message) use ($consumer) {