Skip to content

Commit 7884873

Browse files
committed
* 修复 ForawrdWorker 未设 Logger 报错的问题。
1 parent 4ec0f7f commit 7884873

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

CHANGELOG.md

+4
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,10 @@
33
## HEAD (Unreleased)
44
_(none)_
55

6+
## 0.7.5 (2017-08-11)
7+
8+
* 修复 ForawrdWorker 未设 Logger 报错的问题。
9+
610
## 0.7.4 (2017-08-08)
711

812
* 修复 ForwardWorker 长时间运行后,报 Socket 错误的问题。

src/ForwardWorker.php

+1-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ public function __construct($tubeName, $config)
2525
$config['persistent'] = true;
2626

2727
$this->destQueueName = isset($this->config['destination']['tubeName']) ? $this->config['destination']['tubeName'] : $this->tubeName;
28-
$this->destQueue = new BeanstalkClientProxy(new BeanstalkClient($config));
28+
$this->destQueue = new BeanstalkClientProxy(new BeanstalkClient($config), $this->logger);
2929
$this->destQueue->connect();
3030
$this->destQueue->useTube($this->destQueueName);
3131
}

0 commit comments

Comments
 (0)