diff --git a/src/QuantQueue.php b/src/QuantQueue.php index dd607bf1..524d47ad 100644 --- a/src/QuantQueue.php +++ b/src/QuantQueue.php @@ -7,7 +7,7 @@ /** * Additional handling for Quant queue items. - * + * * @see https://git.drupalcode.org/project/queue_unique */ class QuantQueue extends DatabaseQueue { @@ -41,7 +41,8 @@ public function doCreateItem($data) { 'hash' => static::hash($this->name, $serialized_data), ]); return $query->execute(); - } catch (IntegrityConstraintViolationException $err) { + } + catch (IntegrityConstraintViolationException $err) { return FALSE; } } @@ -87,5 +88,4 @@ public function schemaDefinition() { ); } - -} \ No newline at end of file +} diff --git a/src/QuantQueueFactory.php b/src/QuantQueueFactory.php index d25dbcf4..0ea6470a 100644 --- a/src/QuantQueueFactory.php +++ b/src/QuantQueueFactory.php @@ -1,13 +1,19 @@ connection); - } -} \ No newline at end of file + + /** + * {@inheritdoc} + */ + public function get($name) { + return new QuantQueue($name, $this->connection); + } + +}