yii2-queue
yii2-queue copied to clipboard
yiisoft
Yii2 Queue Extension. Supports DB, Redis, RabbitMQ, Beanstalk and Gearman
Exception 'yii\redis\SocketException' with message 'Failed to read from socket. Redis command was: ZREM cst-group-dataImportQueue2.reserved 99' in /mnt/hgfs/www/cst-group-new/vendor/yiisoft/yii2-redis/src/Connection.php:778 Stack trace: #0 /mnt/hgfs/www/cst-group-new/vendor/yiisoft/yii2-redis/src/Connection.php(763): yii\redis\Connection->parseResponse(Array, '*3\r\n$4\r\nZREM\r\n$...') #1 /mnt/hgfs/www/cst-group-new/vendor/yiisoft/yii2-redis/src/Connection.php(746): yii\redis\Connection->sendCommandInternal('*3\r\n$4\r\nZREM\r\n$...', Array) #2 /mnt/hgfs/www/cst-group-new/vendor/yiisoft/yii2-redis/src/Connection.php(683): yii\redis\Connection->executeCommand('ZREM',...
### Just a regular case of using queue. ### Normal behavior, with no worker hanging. ### I get MySQL server has gone away. `yii queue/listen --verbose --color --isolate=0` if I...
### What steps will reproduce the problem? I set parameter ttr=7200, seconds。 I found a strange phenomenon that the task was not wrong but it was executed after 7200 seconds....
Push in left and pop from right Without this we can have Live Lock because some Jobs added first never wil be attendend if new jobs won't stop arriving |...
| Q | A | ------------- | --- | Is bugfix? | yes | New feature? | yes | Breaks BC? | yes | Tests pass? | yes | Fixed...
change the job id to be something that are not stored in redis, so that we can still push a job from inside a multi block | Q | A...
If I have code that look like this: ```php
If we can use UUID as the ID of the queue, I think we can use MULTI COMMAND in the redis driver to make the performance better
Maybe drivers should only deal with message sourcing and sinking and create new class definitions that are executors That way one could implement more executors. I have issue that I...
### What steps will reproduce the problem? Trying push message to queue from job. ```php class NotificationJob extends BaseObject implements JobInterface { public function execute($queue) { $instances = $this->getInstances(); foreach...
