Lock.php

Go to the documentation of this file.

<?php
namespace Magento\MessageQueue\Model\Plugin\ResourceModel;

class Lock
{
    private $lock;

    public function __construct(\Magento\Framework\MessageQueue\Lock\WriterInterface $lock)
    {
        $this->lock = $lock;
    }

    public function afterSet(\Magento\Framework\App\MaintenanceMode $subject, $result)
    {
        if (!$subject->isOn() && $result) {
            $this->lock->releaseOutdatedLocks();
        }
    }
}