diff --git a/composer.json b/composer.json index 39c8c42f..44ad4cfa 100644 --- a/composer.json +++ b/composer.json @@ -1,11 +1,11 @@ { - "name": "vladimir-yuldashev/laravel-queue-rabbitmq", + "name": "haibian/laravel-queue-rabbitmq", "description": "RabbitMQ driver for Laravel Queue", "license": "MIT", "authors": [ { - "name": "Vladimir Yuldashev", - "email": "misterio92@gmail.com" + "name": "wangfeng5312", + "email": "wangfeng5312@sina.com" } ], "require": { diff --git a/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/Jobs/RabbitMQJob.php b/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/Jobs/RabbitMQJob.php index 60cf04e7..4f0294b8 100644 --- a/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/Jobs/RabbitMQJob.php +++ b/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/Jobs/RabbitMQJob.php @@ -155,7 +155,21 @@ public function release($delay = 0) $this->connection->push($job, $data, $this->getQueue()); } } - + + /** + * Release the job back into the queue.(not delete) + * + * @param int $delay + * + * @throws Exception + * + * @return void + */ + public function sequenceRelease() + { + $this->released = true; + } + /** * Sets the count of attempts at processing this job. *