yii2-queue
yii2-queue copied to clipboard
yiisoft
Yii2 Queue Extension. Supports DB, Redis, RabbitMQ, Beanstalk and Gearman
I noticed that `moveExpired` method can cause problems when multiple workers are running simultaneously. If multiple workers call `zrevrangebyscore` at the same time, before `zremrangebyscore` is called, both will get...
Channel column value overwrite and downstream error: `SQLSTATE[07002]: [Microsoft][ODBC Driver 11 for SQL Server]COUNT field incorrect or syntax error` **Steps:** 1. Add queue config 2. Create Job via gii/Job 2....
| Q | A | ------------- | --- | Is bugfix? | yes | New feature? | no | Breaks BC? | no | Tests pass? | yes | Fixed...
### What steps will reproduce the problem? Make DB queue with 200k+ jobs on delayed list ### What's expected? fetching jobs from queue should be fast ### What do you...
I have been able to consistently reproduce this error within SQL Server 2012. ``` "name": "yiisoft/yii2-queue", "version": "2.0.2", "source": { "type": "git", "url": "https://github.com/yiisoft/yii2-queue.git", "reference": "8c2b337f7d9ea934c2affdfc21c9fb387d0a0773" }, "dist": { "type":...
fix #173
What about the solution such this? It's not finished yet, just to pic the idea of using `yii/redis/Mutex` to solve the concurrency issue. | Q | A | ------------- |...
Can we add functionality to take off reserve from job to make it immediately available for workers? After job being reserved we need to wait TTR before job expired and...
### What steps will reproduce the problem? Run the status command when the configured tube does not exist. ### What's expected? Tubes in beanstalk are ephemeral; they are created and...
hello,I got a delay jobID and I want to stop it later. how to stop it ? this is my code ``` $jobID = Yii::$app->queue->delay(1234)->push(new \console\jobs\DemoJob([ 'function' => "test1", 'params'...
Related #87. The code is simple and anyone can create it inside own project. But maybe need to create abstract class which will include stopping logics, and cache component should...
