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

18 lines
380 B
JavaScript
Executable File

const { EventService } = require("m3o/event");
// Publish a message to the event stream.
async function publishAmessage() {
let eventService = new EventService(process.env.MICRO_API_TOKEN);
let rsp = await eventService.publish({
message: {
id: "1",
type: "signup",
user: "john",
},
topic: "user",
});
console.log(rsp);
}
publishAmessage();