NotificationsYou must be signed in to change notification settings
Fork9.7k
Star30.8k

Commitfbd3a63

committed

bug#52158 [Messenger] Fix graceful exit with ids (HypeMC)

This PR was merged into the 6.3 branch.Discussion----------[Messenger] Fix graceful exit with ids| Q | A| ------------- | ---| Branch? | 6.3| Bug fix? | yes| New feature? | no| Deprecations? | no| Tickets | -| License | MITOne last case I missed in#52080Commits-------1fc56bb [Messenger] Fix graceful exit with ids

2 parents7b48483 +1fc56bb commitfbd3a63Copy full SHA for fbd3a63

File tree

1 file changed

-1

lines changed

src/Symfony/Component/Messenger/Command
- FailedMessagesRetryCommand.php

1 file changed

-1

lines changed

`‎src/Symfony/Component/Messenger/Command/FailedMessagesRetryCommand.php‎`

Lines changed: 8 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -124,7 +124,10 @@ protected function execute(InputInterface $input, OutputInterface $output): int`
`124`	`124`	`}`
`125`	`125`
`126`	`126`	`$this->retrySpecificIds($failureTransportName,$ids,$io,$shouldForce);`
`127`		`-$io->success('All done!');`
	`127`	`+`
	`128`	`+if (!$this->shouldStop) {`
	`129`	`+$io->success('All done!');`
	`130`	`+ }`
`128`	`131`
`129`	`132`	`return0;`
`130`	`133`	`}`
`@@ -255,6 +258,10 @@ private function retrySpecificIds(string $failureTransportName, array $ids, Symf`
`255`	`258`
`256`	`259`	`$singleReceiver =newSingleMessageReceiver($receiver,$envelope);`
`257`	`260`	`$this->runWorker($failureTransportName,$singleReceiver,$io,$shouldForce);`
	`261`	`+`
	`262`	`+if ($this->shouldStop) {`
	`263`	`+break;`
	`264`	`+ }`
`258`	`265`	`}`
`259`	`266`	`}`
`260`	`267`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Uh oh!

Commitfbd3a63

File tree

1 file changed

1 file changed

`‎src/Symfony/Component/Messenger/Command/FailedMessagesRetryCommand.php‎`

0 commit comments