2015-07-11 5 views
0

Привет есть PHP приложение, в котором я поставить какую-то работу по https://github.com/pda/pheanstalk/запустить beanstalkd задание поместить из PHP трубки fivebeans рабочего

$pheanstalk 
      ->useTube('testtube') 
      ->put(json_encode(array('hello' => 'mdjaman'))); 

то я хочу использовать nodejs https://www.npmjs.com/package/fivebeans работника для обработки задания; неосновательно я пропустил что-то в великолепной документации пяти бобов. Может кто-то указать мне на правильный путь. Вот мой JS файл

var Beanworker = require('fivebeans').worker; 
var options = 
{ 
    id: 'worker_4', 
    host: '0.0.0.0', 
    port: 13000, 
    handlers: 
    { 
     type: 'emitkeys' 
    }, 
    ignoreDefault: true 
} 
var worker = new Beanworker(options); 
worker.start(['testtube']); 
worker.on('info', function(message) { 
    console.log('worker started with msg ' + message); 
}); 
+0

почему downvote? объясните –

+0

Хотя я не голосовал по этому вопросу, я буду отмечать его как «Должен быть улучшен». Я думаю, что и ваша проблема, и ваш вопрос должны быть уточнены. Это сообщение не соответствует должным образом http://stackoverflow.com/help/mcve –

+0

@DanBeaulieu улучшить уверен, что я бы сказал, что вы не поняли? –

ответ

2

в конечном итоге, используя другую реализацию nodestalker

1
  • Высказывание "Это не работает" - не помогает.
  • Beanstalkd обычно запускается на порту 11300, а не 13000
+0

Стоит сказать, что хост и порт связаны с тем, что мое приложение работает на бродячих коробках и приставке для кукловода. И снова не проблема, поставив работу на трубку, все работает в этот момент. Проблема заключается в том, что вы хотите обработать задание с помощью nodejs https://www.npmjs.com/package/fivebeans –

+0

просто хотите, чтобы работник из пяти человек обрабатывал работу –

0

Вы должны

$tt["payload"] = array('hello' => 'mdjaman'); 
$tt ["type"]="testtube";  
$js = json_encode($tt); 
$tid = $beans->useTube('testtube')->put($js);