Skip to content

Commit 3d7e453

Browse files
committed
修复beanstalk无法消费非默认tube的Bug
1 parent bdf5d5a commit 3d7e453

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

src/Queue/Beanstalk.php

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -58,17 +58,17 @@ public function set(string $data, string $queue = 'default', $delay = 0)
5858
* 从队列中获取一个job,需要注意的是获取Job之后不会从队列中删除Job,需
5959
* 明确指定`$isAck=true`才会自动删除.
6060
*
61-
* @param string $queue Tube名字.
61+
* @param string $queue Tube名字(默认会watch此tube).
6262
* @param boolean $isAck 是否从队列中删除,默认是.
6363
* @param int|null $timeout 取Job的超时时间,即`reserve-with-timeout`.
6464
*
65-
* @return Job
65+
* @return false|Job
6666
*/
6767
public function get(string $queue = 'default', $isAck = true, $timeout = null)
6868
{
69-
yield $this->beanstalkTask->useTube($queue);
69+
yield $this->beanstalkTask->watch($queue);
7070
$job = yield $this->beanstalkTask->reserve($timeout);
71-
if ($isAck) {
71+
if ($job && $isAck) {
7272
yield $this->beanstalkTask->delete($job);
7373
}
7474

0 commit comments

Comments
 (0)