1
我已经为Laravel安装了Pheanstalk包(https://github.com/mikelbring/Pheanstalk) 我现在正在跟踪基本示例代码,尝试将作业传递给队列并将其重新取回。Pheanstalk在Laravel,一切都结束了作为一个未处理的响应?
这是我的代码:
Route::get('queue', function()
{
Pheanstalk::useTube('testtube')->put("job payload goes here\n");
$pheanstalk = Pheanstalk::connection();
$job = $pheanstalk
->watch('testtube')
->ignore('default')
->reserve();
echo $job->getData();
$pheanstalk->delete($job);
});
然而,当我运行它,我得到一个“未处理的响应”的错误,像什么已经归还。
Unhandled Exception
Message:
Unhandled response:
Location:
C:\wamp\www\adam\phire\bundles\pheanstalk\pheanstalk\classes\Pheanstalk\Command\PutCommand.php on line 108
Stack Trace:
#0 C:\wamp\www\adam\phire\bundles\pheanstalk\pheanstalk\classes\Pheanstalk\Connection.php(121): Pheanstalk_Command_PutCommand->parseResponse('', NULL)
#1 C:\wamp\www\adam\phire\bundles\pheanstalk\pheanstalk\classes\Pheanstalk.php(511): Pheanstalk_Connection->dispatchCommand(Object(Pheanstalk_Command_PutCommand))
#2 C:\wamp\www\adam\phire\bundles\pheanstalk\pheanstalk\classes\Pheanstalk.php(273): Pheanstalk\Pheanstalk->_dispatch(Object(Pheanstalk_Command_PutCommand))
#3 C:\wamp\www\adam\phire\application\routes.php(45): Pheanstalk\Pheanstalk->put('job payload goe...')
#4 [internal function]: Laravel\Bundle::{closure}()
#5 C:\wamp\www\adam\phire\laravel\routing\route.php(163): call_user_func_array(Object(Closure), Array)
#6 C:\wamp\www\adam\phire\laravel\routing\route.php(124): Laravel\Routing\Route->response()
#7 C:\wamp\www\adam\phire\laravel\laravel.php(167): Laravel\Routing\Route->call()
#8 C:\wamp\www\adam\phire\public\index.php(34): require('C:\wamp\www\ada...')
#9 {main}
是否有人熟悉Pheanstalk并能提供一些帮助?
谢谢 亚当。
不幸的是,我看到的唯一选择是向“Laravel Pheanstalk”捆绑维护者https://github.com/mikelbring/Pheanstalk/issues发送一个错误,或者如果找到修复请求,则发出拉取请求: - / – 2013-04-22 15:11:37