Skip to content

Commit

Permalink
Fixed adapter channel name if several channels in use and adapter cre…
Browse files Browse the repository at this point in the history
…ated from container definitions.
  • Loading branch information
holdmann committed May 26, 2024
1 parent 4167ef3 commit 292ea4a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/QueueFactory.php
Original file line number Diff line number Diff line change
Expand Up @@ -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);
}
Expand Down

0 comments on commit 292ea4a

Please sign in to comment.