Merge pull request #16 from lengqiuqiuqiu/main

判断队列名$queue是否为空

src/Process/Consumer.php

@@ -1,4 +1,5 @@
 <?php
+
 /**
  * This file is part of webman.
  *
@@ -65,6 +66,10 @@ public function onWorkerStart()
                     $consumer = Container::get($class);
                     $connection_name = $consumer->connection ?? 'default';
                     $queue = $consumer->queue;
+                    if (!$queue) {
+                        echo "Consumer {$class} queue not exists\r\n";
+                        continue;
+                    }
                     $this->_consumers[$queue] = $consumer;
                     $connection = Client::connection($connection_name);
                     $connection->subscribe($queue, [$consumer, 'consume']);
@@ -79,6 +84,5 @@ public function onWorkerStart()
                 }
             }
         }
-
     }
 }