flowpack/jobqueue-beanstalkd
Composer 安装命令：
composer require flowpack/jobqueue-beanstalkd
包简介
Implements concrete Queue for the beanstalkd work queue. Requires the packages flowpack/jobqueue-common and pda/pheanstalk package to be installed.
README 文档
README
A job queue backend for the Flowpack.JobQueue.Common package based on beanstalkd.
Usage
Install the package using composer:
composer require flowpack/jobqueue-beanstalkd
If not already installed, that will fetch its requirements, namely jobqueue-common and pda/pheanstalk.
NOTE: This package needs a running beanstalkd server
Now the queue can be configured like this:
Flowpack: JobQueue: Common: queues: 'some-queue': className: 'Flowpack\JobQueue\Beanstalkd\Queue\BeanstalkdQueue' executeIsolated: true options: client: host: 127.0.0.11 port: 11301 defaultTimeout: 50 releaseOptions: priority: 512 delay: 120
Specific options
The BeanstalkdQueue supports following options:
| Option | Type | Default | Description |
|---|---|---|---|
| defaultTimeout | integer | 60 | Number of seconds new messages are waited for before a timeout occurs (This is overridden by a "timeout" argument in the waitAndTake() and waitAndReserve() methods |
| client | array | ['host' => '127.0.0.1', 'port' => 11300] | Beanstalkd connection settings |
Submit options
Additional options supported by JobManager::queue(), BeanstalkdQueue::submit() and the Job\Defer annotation:
| Option | Type | Default | Description |
|---|---|---|---|
| delay | integer | 0 | Number of seconds before a message is marked "ready" after submission. This can be useful to prevent premature execution of jobs (i.e. before entites are persisted) |
| priority | integer | 1024 | Priority of the message. most urgent: 0, least urgent: 4294967295 |
| ttr | integer | 60 | Number of seconds a message is allowed to be reserved before it is released, aborted or finished. NOTE: This option is not available in the releaseOptions! |
Release options
Additional options to be specified via releaseOptions:
| Option | Type | Default | Description |
|---|---|---|---|
| delay | integer | 0 | Number of seconds before a message is marked "ready" after it has been released. |
| priority | integer | 1024 | Priority of the message. most urgent: 0, least urgent: 4294967295 |
License
This package is licensed under the MIT license
Contributions
Pull-Requests are more than welcome. Make sure to read the Code Of Conduct.
统计信息
- 总下载量： 25.9k
- 月度下载量： 0
- 日度下载量： 0
- 收藏数： 6
- 点击次数： 3
- 依赖项目数： 0
- 推荐数： 1
其他信息
- 授权协议： MIT
- 更新时间： 2016-06-28