Skip to content

Commit 9bf14e7

Browse files
committed
[Messenger] Remove deprecated StopWorkerOnSignalsListener
1 parent fa4d0b8 commit 9bf14e7

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Tests/Fixtures/long_receiver.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717
use Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection;
1818
use Symfony\Component\Messenger\Envelope;
1919
use Symfony\Component\Messenger\EventListener\DispatchPcntlSignalListener;
20-
use Symfony\Component\Messenger\EventListener\StopWorkerOnSignalsListener;
2120
use Symfony\Component\Messenger\MessageBusInterface;
2221
use Symfony\Component\Messenger\Transport\Serialization\Serializer;
2322
use Symfony\Component\Messenger\Worker;
@@ -33,7 +32,6 @@
3332
$connection = Connection::fromDsn(getenv('DSN'));
3433
$receiver = new AmqpReceiver($connection, $serializer);
3534
$eventDispatcher = new EventDispatcher();
36-
$eventDispatcher->addSubscriber(new StopWorkerOnSignalsListener());
3735
$eventDispatcher->addSubscriber(new DispatchPcntlSignalListener());
3836

3937
$worker = new Worker(['the_receiver' => $receiver], new class() implements MessageBusInterface {
@@ -49,5 +47,7 @@ public function dispatch($envelope, array $stamps = []): Envelope
4947
}
5048
}, $eventDispatcher);
5149

50+
pcntl_signal(15, fn () => $worker->stop());
51+
5252
echo "Receiving messages...\n";
5353
$worker->run();

0 commit comments

Comments
 (0)