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 1717use Symfony \Component \Messenger \Bridge \Amqp \Transport \Connection ;
1818use Symfony \Component \Messenger \Envelope ;
1919use Symfony \Component \Messenger \EventListener \DispatchPcntlSignalListener ;
20- use Symfony \Component \Messenger \EventListener \StopWorkerOnSigtermSignalListener ;
20+ use Symfony \Component \Messenger \EventListener \StopWorkerOnSignalsListener ;
2121use Symfony \Component \Messenger \MessageBusInterface ;
2222use Symfony \Component \Messenger \Transport \Serialization \Serializer ;
2323use Symfony \Component \Messenger \Worker ;
3333$ connection = Connection::fromDsn (getenv ('DSN ' ));
3434$ receiver = new AmqpReceiver ($ connection , $ serializer );
3535$ eventDispatcher = new EventDispatcher ();
36- $ eventDispatcher ->addSubscriber (new StopWorkerOnSigtermSignalListener ());
36+ $ eventDispatcher ->addSubscriber (new StopWorkerOnSignalsListener ());
3737$ eventDispatcher ->addSubscriber (new DispatchPcntlSignalListener ());
3838
3939$ worker = new Worker (['the_receiver ' => $ receiver ], new class () implements MessageBusInterface {
You can’t perform that action at this time.
0 commit comments