介绍

消息模块。在主进程和子进程之间发送消息。

使用方法

const { childMessage } = require('ee-core/message');

API列表

send(eventName, params = {}, receiver)

• eventName [] - 监听的事件名称
• params [] - 参数
• receiver [] - 接收者，值：'job' | 'task'，默认：'task'

向主进程发消息。task.on() 监听的事件。

const timerTask = this.myJob.exec('./jobs/example/timer', {jobId});
timerTask.emitter.on('job-timer-progress', (data) => {
  // ...
})

// 发送
childMessage.send(eventName, {jobId, number:0, pid:0});

sendToMain(eventName, params = {})

• eventName [] - 监听的事件名称
• params [] - 参数

向主进程发消息，myjob.on() 监听的事件。

# 在主进程任务监听
myjob.on('job-timer-progress', (data) => {
  // some things
})

# 在子进程发送
let eventName = 'job-timer-progress';
childMessage.sendToMain(eventName, {jobId, number});