Buzzi Event Producer and Consumer

node v8.17.0
version: 3.0.0
endpointsharetweet
Require `buzzi-sdk-node`.
const buzzi = require("buzzi-sdk-node")
Instantiate your Buzzi Service.
const id = process.env.BUZZI_API_ID || '145fc8a1-6782-400d-aa7a-66c930acc318'; const secret = process.env.BUZZI_API_SECRET || 'fuNFRdbjhZRzCHVqDHkYGBX7Qv4YaGVoED4rioA8ufjb4vsT8awKtu2oP2QkoNys'; const service = new buzzi.Service({ id, secret });
Send your Event to Buzzi.
let response = await service.send('buzzi.generic.test', { message: "Hello, World!", timestamp: new Date(), });
Wait for event to be processed. Since this Buzzi Service is subscribed to itself for the `buzzi.generic.test` event, we'll be pulling that same event in the step.
const Promise = require('bluebird'); await Promise.resolve(true).delay(2000);
Fetch your Event from Buzzi.
let delivery = await service.fetch();
// confirm that the event was successfully processed if (delivery) { let confirmation = await service.confirm(delivery); }
Loading…

no comments

    sign in to comment