File tree Expand file tree Collapse file tree 6 files changed +6
-83
lines changed
Filter options
Bridge/Amqp/Tests/Fixtures Expand file tree Collapse file tree 6 files changed +6
-83
lines changed
Original file line number Diff line number Diff line change @@ -172,8 +172,8 @@ Messenger
172
172
173
173
* Add parameter ` $isSameDatabase ` to ` DoctrineTransport::configureSchema() `
174
174
* Remove ` MessageHandlerInterface ` and ` MessageSubscriberInterface ` , use ` #[AsMessageHandler] ` instead
175
- * Remove ` StopWorkerOnSigtermSignalListener ` in favor of
176
- ` StopWorkerOnSignalsListener ` and make it configurable with SIGINT and
175
+ * Remove ` StopWorkerOnSigtermSignalListener ` in favor of using the ` SignalableCommandInterface `
176
+ * Remove ` StopWorkerOnSignalsListener ` in favor of using the ` SignalableCommandInterface `
177
177
* Remove ` Symfony\Component\Messenger\Transport\InMemoryTransport ` and
178
178
` Symfony\Component\Messenger\Transport\InMemoryTransportFactory ` in favor of
179
179
` Symfony\Component\Messenger\Transport\InMemory\InMemoryTransport ` and
Original file line number Diff line number Diff line change 108
108
use Symfony \Component \Messenger \Attribute \AsMessageHandler ;
109
109
use Symfony \Component \Messenger \Bridge as MessengerBridge ;
110
110
use Symfony \Component \Messenger \Command \StatsCommand ;
111
- use Symfony \Component \Messenger \EventListener \StopWorkerOnSignalsListener ;
112
111
use Symfony \Component \Messenger \Handler \BatchHandlerInterface ;
113
112
use Symfony \Component \Messenger \MessageBus ;
114
113
use Symfony \Component \Messenger \MessageBusInterface ;
@@ -2035,12 +2034,6 @@ private function registerMessengerConfiguration(array $config, ContainerBuilder
2035
2034
$ container ->getDefinition ('messenger.transport.beanstalkd.factory ' )->addTag ('messenger.transport_factory ' );
2036
2035
}
2037
2036
2038
- if (!class_exists (StopWorkerOnSignalsListener::class)) {
2039
- $ container ->removeDefinition ('messenger.listener.stop_worker_signals_listener ' );
2040
- } elseif ($ config ['stop_worker_on_signals ' ]) {
2041
- $ container ->getDefinition ('messenger.listener.stop_worker_signals_listener ' )->replaceArgument (0 , $ config ['stop_worker_on_signals ' ]);
2042
- }
2043
-
2044
2037
if (null === $ config ['default_bus ' ] && 1 === \count ($ config ['buses ' ])) {
2045
2038
$ config ['default_bus ' ] = key ($ config ['buses ' ]);
2046
2039
}
Original file line number Diff line number Diff line change 23
23
use Symfony \Component \Messenger \EventListener \SendFailedMessageToFailureTransportListener ;
24
24
use Symfony \Component \Messenger \EventListener \StopWorkerOnCustomStopExceptionListener ;
25
25
use Symfony \Component \Messenger \EventListener \StopWorkerOnRestartSignalListener ;
26
- use Symfony \Component \Messenger \EventListener \StopWorkerOnSignalsListener ;
27
26
use Symfony \Component \Messenger \Handler \RedispatchMessageHandler ;
28
27
use Symfony \Component \Messenger \Middleware \AddBusNameStampMiddleware ;
29
28
use Symfony \Component \Messenger \Middleware \DispatchAfterCurrentBusMiddleware ;
201
200
->tag ('kernel.event_subscriber ' )
202
201
->tag ('monolog.logger ' , ['channel ' => 'messenger ' ])
203
202
204
- ->set ('messenger.listener.stop_worker_signals_listener ' , StopWorkerOnSignalsListener::class)
205
- ->deprecate ('6.4 ' , 'symfony/messenger ' , 'The "%service_id%" service is deprecated, use the "Symfony\Component\Console\Command\SignalableCommandInterface" instead. ' )
206
- ->args ([
207
- null ,
208
- service ('logger ' )->ignoreOnInvalid (),
209
- ])
210
- ->tag ('kernel.event_subscriber ' )
211
- ->tag ('monolog.logger ' , ['channel ' => 'messenger ' ])
212
-
213
203
->set ('messenger.listener.stop_worker_on_stop_exception_listener ' , StopWorkerOnCustomStopExceptionListener::class)
214
204
->tag ('kernel.event_subscriber ' )
215
205
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 ();
Original file line number Diff line number Diff line change @@ -6,8 +6,8 @@ CHANGELOG
6
6
7
7
* Add parameter ` $isSameDatabase ` to ` DoctrineTransport::configureSchema() `
8
8
* Remove ` MessageHandlerInterface ` and ` MessageSubscriberInterface ` , use ` #[AsMessageHandler] ` instead
9
- * Remove ` StopWorkerOnSigtermSignalListener ` in favor of
10
- ` StopWorkerOnSignalsListener ` and make it configurable with SIGINT and
9
+ * Remove ` StopWorkerOnSigtermSignalListener ` in favor of using the ` SignalableCommandInterface `
10
+ * Remove ` StopWorkerOnSignalsListener ` in favor of using the ` SignalableCommandInterface `
11
11
* Remove ` Symfony\Component\Messenger\Transport\InMemoryTransport ` and
12
12
` Symfony\Component\Messenger\Transport\InMemoryTransportFactory ` in favor of
13
13
` Symfony\Component\Messenger\Transport\InMemory\InMemoryTransport ` and
Load Diff This file was deleted.
You can’t perform that action at this time.
0 commit comments