Lock a list of object of the same entity to be executed by a single processor. When the lock is aquire, the lock ID generated can be use by a processor to execute action on that locked list.
- Use version
1.0-devfor Symfony 4.0+.
This bundle is available via composer, find it on packagist.
Run :
composer require webonaute/doctrine-datalocking-bundle 1.0-dev
Add this snipped code to your entity.
use Webonaute\DoctrineDataLockingBundle\Entity\ProcessLock;
...
/**
* @var ProcessLock
*
* @ORM\Embedded(class=ProcessLock::class)
*/
private $processLock;
...
public function __construct()
{
...
$this->processLock = new ProcessLock();
}
/**
* @return ProcessLock
*/
public function getProcessLock(): ProcessLock
{
return $this->processLock;
}
while (null !== $lockId = $dataLockerService->lock(Entity::class, 500, $extraWhere, $lockAt)) {
$this->queue->push($lockId);
}
$lockedEntities = $dataLockerService->findLocked(Entity::class, $lockId);
This will simply unlock the object. To consume the entity object, use deleteLocked method.
$lockedEntities = $dataLockerService->unlock(Entity::class, $lockId);
This method will consume the entity object by deleting it from the database.
$lockedEntities = $dataLockerService->deleteLocked(Entity::class, $lockId);
See LICENSE.