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) {