RetailCRM-Mirror/service-bundle
1
0
Fork 0
mirror of synced 2024-11-22 04:46:07 +03:00
Code Issues Projects Releases Wiki Activity

add-ttl-for-middleware

Browse Source
This commit is contained in:
Сергей Кривич 2023-10-18 14:15:32 +03:00
parent a104eebf2a
commit f15d9a2a86
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
Messenger/Middleware/LockableMessageMiddleware.php
View File

@ -21,9 +21,15 @@ 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;
} }
/** /**
@ -39,7 +45,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), null); $lock = $this->lockFactory->createLock($this->objectHash($message), $this->ttl);
if (!$lock->acquire()) { if (!$lock->acquire()) {
return $envelope; return $envelope;
} }