Skip to content

Commit a797648

Browse files
committed
delay strategy
1 parent b2c5d72 commit a797648

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

pkg/amqp-bunny/AmqpContext.php

+1-1
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,7 @@ public function createConsumer(PsrDestination $destination)
128128
*/
129129
public function createProducer()
130130
{
131-
$producer = new AmqpProducer($this->getBunnyChannel(), $this);
131+
$producer = new AmqpProducer($this->getBunnyChannel(), $this);
132132
$producer->setDelayStrategy($this->delayStrategy);
133133

134134
return $producer;

pkg/amqp-ext/AmqpConnectionFactory.php

+1-1
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ public function __construct($config = 'amqp://')
8787
public function createContext()
8888
{
8989
if ($this->config['lazy']) {
90-
$context = new AmqpContext(function () {
90+
$context = new AmqpContext(function () {
9191
return $this->createExtContext($this->establishConnection());
9292
}, $this->config['receive_method']);
9393
$context->setDelayStrategy($this->delayStrategy);

pkg/amqp-tools/Tests/RabbitMqDlxDelayStrategyTest.php

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,8 @@
55
use Enqueue\AmqpTools\DelayStrategy;
66
use Enqueue\AmqpTools\RabbitMqDlxDelayStrategy;
77
use Enqueue\Test\ClassExtensionTrait;
8-
use Interop\Amqp\AmqpDestination;
98
use Interop\Amqp\AmqpContext;
9+
use Interop\Amqp\AmqpDestination;
1010
use Interop\Amqp\AmqpProducer;
1111
use Interop\Amqp\Impl\AmqpMessage;
1212
use Interop\Amqp\Impl\AmqpQueue;

0 commit comments

Comments
 (0)