Skip to content

Commit ed3f457

Browse files
Merge branch '4.3' into 4.4
* 4.3: [Security/Http] fix typo in deprecation message Various tweaks 3.4 Various tweaks 4.3 [PhpUnit] Fix usleep mock return value [Lock] use Predis\ClientInterface instead of Predis\Client Fix version typo in deprecation notice Make legacy "wrong" RFC2047 encoding apply only to one header
2 parents 45bdaaf + 221a92f commit ed3f457

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
@@ -185,7 +185,7 @@ private function runWorker(ReceiverInterface $receiver, SymfonyStyle $io, bool $
185185

186186
$count = 0;
187187
try {
188-
$worker->run([], function (?Envelope $envelope) use ($worker, $io, &$count) {
188+
$worker->run([], function (?Envelope $envelope) use ($worker, &$count) {
189189
++$count;
190190
if (null === $envelope) {
191191
$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)