Skip to content
This repository has been archived by the owner on Jun 2, 2023. It is now read-only.

Commit

Permalink
Merge pull request #4 from AntonTrekov/bugfix/requeue-transaction-commit
Browse files Browse the repository at this point in the history
Fixed batch republishing bug - hotfix
  • Loading branch information
AntonTrekov committed Apr 26, 2019
2 parents e8b010b + b1ba78a commit 451f620
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions src/Service/QueueService.php
Expand Up @@ -127,11 +127,9 @@ public function createQueue(QueueInterface $queueable): QueueEntityInterface
return $this->save($this->entityFactory->createQueue($queueable));
}

public function flush(QueueEntityInterface $entity = null): QueueEntityInterface
public function flush(QueueEntityInterface $entity = null): void
{
$this->repository->flush($entity);

return $entity;
}

public function save(QueueEntityInterface $entity): QueueEntityInterface
Expand Down

0 comments on commit 451f620

Please sign in to comment.