Compare commits
No commits in common. "master" and "v1.0.3" have entirely different histories.
3 changed files with 4 additions and 10 deletions
|
@ -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()
|
||||||
];
|
];
|
||||||
|
|
|
@ -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;
|
||||||
}
|
}
|
||||||
|
|
|
@ -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",
|
||||||
|
|
Loading…
Add table
Reference in a new issue