//任务设置 var MartinetWorker = require('martinet').Worker;
var WORKER_PORT = 3000; var worker = new MartinetWorker(WORKER_PORT, { martinet_url: '127.0.0.1', martinet_port: '8089' });
//任务定义 worker.on('task_name', function(taskId, data, callback) { // do a thing.
// if it's successful, callback(), // if there's an error, callback(err)
});
//任务执行,分三种方式:立即执行 延时执行 或周期执行 martinet.execute({ worker: 'WORKER_NAME', name: 'task_name', description: 'Do a thing' // Used in the backend so it's easier to lookup tasks later }, args);