Files
services/examples/mq/publish/node/publishAMessage.js

18 lines
403 B
JavaScript
Executable File

const { MqService } = require("m3o/mq");
// Publish a message. Specify a topic to group messages for a specific topic.
async function publishAmessage() {
let mqService = new MqService(process.env.MICRO_API_TOKEN);
let rsp = await mqService.publish({
message: {
id: "1",
type: "signup",
user: "john",
},
topic: "events",
});
console.log(rsp);
}
publishAmessage();