diff --git a/src/Queue/Queue.php b/src/Queue/Queue.php
index dcd426c..06d9121 100644
--- a/src/Queue/Queue.php
+++ b/src/Queue/Queue.php
@@ -20,7 +20,7 @@ public static function getQueue(array $config, Logs $logger)
             //最多尝试连接3次
             for ($i=0; $i < 3; $i++) {
                 $connection=$classQueue::getConnection($config, $logger);
-                if (is_object($connection)) {
+                if ($connection && is_object($connection)) {
                     break;
                 }
             }