Commite04298b

committed

Fix

1 parente96f873 commite04298bCopy full SHA for e04298b

File tree

-2

lines changed

-2

lines changed

Lines changed: 5 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -11,6 +11,7 @@`
`11`	`11`
`12`	`12`	`namespaceSymfony\Component\Messenger\Middleware;`
`13`	`13`
	`14`	`+useSymfony\Component\Lock\Key;`
`14`	`15`	`useSymfony\Component\Lock\LockFactory;`
`15`	`16`	`useSymfony\Component\Messenger\Envelope;`
`16`	`17`	`useSymfony\Component\Messenger\Message\LockableMessageInterface;`
`@@ -39,9 +40,11 @@ public function handle(Envelope $envelope, StackInterface $stack): Envelope`
`39`	`40`	`if (null ===$envelope->last(ReceivedStamp::class)) {`
`40`	`41`	`if ($messageinstanceof LockableMessageInterface) {`
`41`	`42`	`// If we're trying to dispatch a lockable message.`
`42`		`-$key =$message->getKey();`
	`43`	`+$keyResource =$message->getKey();`
	`44`	`+`
	`45`	`+if (null !==$keyResource) {`
	`46`	`+$key =newKey($keyResource);`
`43`	`47`
`44`		`-if (null !==$key) {`
`45`	`48`	`// The acquire call must be done before stamping the message`
`46`	`49`	`// in order to have the full state of the key in the stamp.`
`47`	`50`	`$lock =$messageinstanceof TTLAwareLockableMessageInterface`

Comments

(0)