Messenger/Middleware/LockableMessageMiddleware.php

@@ -21,15 +21,9 @@ class LockableMessageMiddleware implements MiddlewareInterface
      */
     private $lockFactory;
 
-    /**
+    public function __construct(LockFactory $lockFactory)
-     * @var int|null
-     */
-    private $ttl;
-
-    public function __construct(LockFactory $lockFactory, int $ttl = null)
     {
         $this->lockFactory = $lockFactory;
-        $this->ttl = $ttl;
     }
 
     /**
@@ -45,7 +39,7 @@ class LockableMessageMiddleware implements MiddlewareInterface
         $message = $envelope->getMessage();
 
         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()) {
                 return $envelope;
             }