File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 17
17
use Symfony \Component \Messenger \Bridge \Amqp \Transport \Connection ;
18
18
use Symfony \Component \Messenger \Envelope ;
19
19
use Symfony \Component \Messenger \EventListener \DispatchPcntlSignalListener ;
20
- use Symfony \Component \Messenger \EventListener \StopWorkerOnSignalsListener ;
21
20
use Symfony \Component \Messenger \MessageBusInterface ;
22
21
use Symfony \Component \Messenger \Transport \Serialization \Serializer ;
23
22
use Symfony \Component \Messenger \Worker ;
33
32
$ connection = Connection::fromDsn (getenv ('DSN ' ));
34
33
$ receiver = new AmqpReceiver ($ connection , $ serializer );
35
34
$ eventDispatcher = new EventDispatcher ();
36
- $ eventDispatcher ->addSubscriber (new StopWorkerOnSignalsListener ());
37
35
$ eventDispatcher ->addSubscriber (new DispatchPcntlSignalListener ());
38
36
39
37
$ worker = new Worker (['the_receiver ' => $ receiver ], new class () implements MessageBusInterface {
@@ -49,5 +47,7 @@ public function dispatch($envelope, array $stamps = []): Envelope
49
47
}
50
48
}, $ eventDispatcher );
51
49
50
+ pcntl_signal (15 , fn () => $ worker ->stop ());
51
+
52
52
echo "Receiving messages... \n" ;
53
53
$ worker ->run ();
You can’t perform that action at this time.
0 commit comments