onWorkerStart = function() { Channel\Client::on('test event', function($event_data){ echo 'test event triggered event_data :'; var_dump($event_data); }); Timer::add(5, function(){ Channel\Client::publish('test event', 'some data'); }); }; Worker::runAll();