diff --git a/src/QueueFactory.php b/src/QueueFactory.php index ef35c9b8..e6b963d0 100644 --- a/src/QueueFactory.php +++ b/src/QueueFactory.php @@ -76,7 +76,7 @@ private function create(string $channel): QueueInterface if (isset($this->channelConfiguration[$channel])) { $definition = $this->channelConfiguration[$channel]; $this->checkDefinitionType($channel, $definition); - $adapter = $this->createFromDefinition($channel, $definition); + $adapter = $this->createFromDefinition($channel, $definition)->withChannel($channel); return $this->queue->withChannelName($channel)->withAdapter($adapter); }