Skip to content

Commit 221a92f

Browse files
committed
Various tweaks 4.3
1 parent b344d49 commit 221a92f

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

Command/FailedMessagesRetryCommand.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -187,7 +187,7 @@ private function runWorker(ReceiverInterface $receiver, SymfonyStyle $io, bool $
187187

188188
$count = 0;
189189
try {
190-
$worker->run([], function (?Envelope $envelope) use ($worker, $io, &$count) {
190+
$worker->run([], function (?Envelope $envelope) use ($worker, &$count) {
191191
++$count;
192192
if (null === $envelope) {
193193
$worker->stop();

Tests/WorkerTest.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -378,7 +378,7 @@ public function testWorkerWithDecorator()
378378
$worker = new Worker([$receiver], $bus);
379379
$workerWithDecorator = new StopWhenMessageCountIsExceededWorker($worker, 2);
380380
$processedEnvelopes = [];
381-
$workerWithDecorator->run([], function (?Envelope $envelope) use ($worker, &$processedEnvelopes) {
381+
$workerWithDecorator->run([], function (?Envelope $envelope) use (&$processedEnvelopes) {
382382
if (null !== $envelope) {
383383
$processedEnvelopes[] = $envelope;
384384
}

0 commit comments

Comments
 (0)