1
0
Fork 0
mirror of synced 2025-04-15 06:50:58 +00:00

Compare commits

..

No commits in common. "master" and "v1.0.3" have entirely different histories.

3 changed files with 4 additions and 10 deletions

View file

@ -105,7 +105,7 @@ abstract class CommandMessage
public function __serialize(): array public function __serialize(): array
{ {
return [ return [
'commandName' => $this->getCommandName(), 'command' => $this->getCommandName(),
'arguments' => $this->getArguments(), 'arguments' => $this->getArguments(),
'options' => $this->getOptions() 'options' => $this->getOptions()
]; ];

View file

@ -21,15 +21,9 @@ class LockableMessageMiddleware implements MiddlewareInterface
*/ */
private $lockFactory; private $lockFactory;
/** public function __construct(LockFactory $lockFactory)
* @var int|null
*/
private $ttl;
public function __construct(LockFactory $lockFactory, int $ttl = null)
{ {
$this->lockFactory = $lockFactory; $this->lockFactory = $lockFactory;
$this->ttl = $ttl;
} }
/** /**
@ -45,7 +39,7 @@ class LockableMessageMiddleware implements MiddlewareInterface
$message = $envelope->getMessage(); $message = $envelope->getMessage();
if ($envelope->all(ReceivedStamp::class) && $message instanceof LockableMessage) { if ($envelope->all(ReceivedStamp::class) && $message instanceof LockableMessage) {
$lock = $this->lockFactory->createLock($this->objectHash($message), $this->ttl); $lock = $this->lockFactory->createLock($this->objectHash($message), null);
if (!$lock->acquire()) { if (!$lock->acquire()) {
return $envelope; return $envelope;
} }

View file

@ -15,7 +15,7 @@
"symfony/framework-bundle": "^4.0|^5.0", "symfony/framework-bundle": "^4.0|^5.0",
"symfony/serializer": "^5.2", "symfony/serializer": "^5.2",
"symfony/http-kernel": "^4.0|^5.0", "symfony/http-kernel": "^4.0|^5.0",
"symfony/validator": "^4.0|^5.3", "symfony/validator": "^4.0|^5.0",
"symfony/security-guard": "^4.0|^5.0", "symfony/security-guard": "^4.0|^5.0",
"symfony/console": "^5.2", "symfony/console": "^5.2",
"symfony/messenger": "^5.2", "symfony/messenger": "^5.2",