How to send messages from worker to parent?

[omar-dulaimi]

Hello,

I have been going through the examples in the repo, and there was something weird. I could not receive messages sent from inside a Bree Job.

I can see in the logs that messages are getting sent, but in the file where I define Bree, I have a log statement there, that never gets executed!

So, could you provide a very minimal working example on how to do that?

• worker

import { parentPort } from "worker_threads";
console.log("in worker!");
parentPort.postMessage("bye!")

• bree

const bree = new Bree({
  doRootCheck: false,
  root: false,
  jobs: [
    {
      name: "main-job",
      path: path.resolve(__dirname, "jobs", "main-job.js"),
      interval: "2s",
    },
  ],
});

if (parentPort) {
  parentPort.on("message", (message) => {
    console.log("message on bree: ", message);
  });
}

await bree.start("main-job");

[titanism]

You need to use the option workerMessageHandler, see https://github.com/breejs/bree.