Commit7dfa027

committed

[Messenger] Log whenSIGTERM is received

1 parent7fdaf13 commit7dfa027Copy full SHA for 7dfa027

File tree

+17

-1

lines changed

+17

-1

lines changed

Lines changed: 3 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -192,6 +192,9 @@`
`192`	`192`	`->tag('monolog.logger', ['channel' =>'messenger'])`
`193`	`193`
`194`	`194`	`->set('messenger.listener.stop_worker_on_sigterm_signal_listener', StopWorkerOnSigtermSignalListener::class)`
	`195`	`+ ->args([`
	`196`	`+service('logger')->ignoreOnInvalid(),`
	`197`	`+ ])`
`195`	`198`	`->tag('kernel.event_subscriber')`
`196`	`199`
`197`	`200`	`->set('messenger.listener.stop_worker_on_stop_exception_listener', StopWorkerOnCustomStopExceptionListener::class)`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,7 @@ CHANGELOG`
`6`	`6`
`7`	`7`	* Add`StopWorkerExceptionInterface` and its implementation`StopWorkerException` to stop the worker.
`8`	`8`	`* Added log when worker should stop.`
	`9`	+* Added log when`SIGTERM` is received.
`9`	`10`
`10`	`11`	`5.3`
`11`	`12`	`---`

Lines changed: 13 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -11,6 +11,7 @@`
`11`	`11`
`12`	`12`	`namespaceSymfony\Component\Messenger\EventListener;`
`13`	`13`
	`14`	`+usePsr\Log\LoggerInterface;`
`14`	`15`	`useSymfony\Component\EventDispatcher\EventSubscriberInterface;`
`15`	`16`	`useSymfony\Component\Messenger\Event\WorkerStartedEvent;`
`16`	`17`
`@@ -19,9 +20,20 @@`
`19`	`20`	`*/`
`20`	`21`	`class StopWorkerOnSigtermSignalListenerimplements EventSubscriberInterface`
`21`	`22`	`{`
	`23`	`+private$logger;`
	`24`	`+`
	`25`	`+publicfunction__construct(LoggerInterface$logger =null)`
	`26`	`+ {`
	`27`	`+$this->logger =$logger;`
	`28`	`+ }`
	`29`	`+`
`22`	`30`	`publicfunctiononWorkerStarted(WorkerStartedEvent$event):void`
`23`	`31`	`{`
`24`		`-pcntl_signal(\SIGTERM,staticfunction ()use ($event) {`
	`32`	`+pcntl_signal(\SIGTERM,function ()use ($event) {`
	`33`	`+if (null !==$this->logger) {`
	`34`	`+$this->logger->info('Received SIGTERM signal.');`
	`35`	`+ }`
	`36`	`+`
`25`	`37`	`$event->getWorker()->stop();`
`26`	`38`	`});`
`27`	`39`	`}`

Comments

(0)