diff --git a/src/Pdo/ReplyQueue.php b/src/Pdo/ReplyQueue.php index e7f63dc..9863319 100644 --- a/src/Pdo/ReplyQueue.php +++ b/src/Pdo/ReplyQueue.php @@ -32,6 +32,7 @@ public function __construct(?string $name, \PDO $pdo, \DateTimeZone $dbTz) if (($name ?? "") === "") { $name = "_rpc_replies"; + $this->name = $name; $this->setCorrelationId(Uuid::uuid4()->getHex()); $this->declareQueue(); }