私のメイン Node インスタンスは、 Kueに追加する新しいジョブに関する情報を含むオブジェクトである(組み込みの Nodeprocess.send()
とを使用して) IPC 経由でメッセージを受け入れるワーカー プロセスを fork します。次に、それらのジョブを処理します。process.on('message'...
私のメイン Node インスタンスは次のように呼び出します。
worker.send({jobType:'filesystem', operation: 'delete', path: fileDir});
ワーカー インスタンスは次のように動作します。
jobs.create(message.jobType, message).save();
jobs.process('filesystem', function(job, done) {
fs.delete(job.data.path, function(err) {
done(err);
});
});
ジョブは正常に完了します。
ジョブが完了したときにメイン Node インスタンスでコールバックのような機能を取得するにはどうすればよいですか? ワーカー インスタンスからメイン ノード インスタンスに結果を返すにはどうすればよいですか?