We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ddb978a commit 8a5a1b4Copy full SHA for 8a5a1b4
src/Queue/Connectors/RabbitMQConnector.php
@@ -63,7 +63,10 @@ public function connect(array $config): Queue
63
64
if ($factory instanceof DelayStrategyAware) {
65
$delayStrategy = isset($config['options']['queue']['delay_strategy']) ? $config['options']['queue']['delay_strategy'] : 'RabbitMqDelayPluginDelayStrategy';
66
- $factory->setDelayStrategy(new $delayStrategy());
+ if ($delayStrategy == 'RabbitMqDlxDelayStrategy')
67
+ $factory->setDelayStrategy(new RabbitMqDlxDelayStrategy());
68
+ else
69
+ $factory->setDelayStrategy(new RabbitMqDelayPluginDelayStrategy());
70
}
71
72
/** @var AmqpContext $context */
0 commit comments