修复

imiphp · Mar 29, 2022 · 2651f49 · 2651f49
1 parent 867aeb1
commit 2651f49
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/Base/Traits/TAMQP.php b/src/Base/Traits/TAMQP.php
@@ -96,6 +96,7 @@ protected function getConnection(): AbstractConnection
         $poolName = null;
         if (null === $this->poolName)
         {
+            $class = BeanFactory::getObjectClass($this);
             $connectionConfig = AnnotationManager::getClassAnnotations($class, Connection::class)[0] ?? null;
             $connectionByPool = false;
             if ($connectionConfig)