queue-novatics

Installation

yarn add queue-novatics

A simple example

Producer

const { send } = require("queue-novatics");

const config = {
  connection:
    "Endpoint=sb://kafkaexample.servicebus.windows.net/;SharedAccessKeyName=kafkaexample;SharedAccessKey=xIVvZp6OHCBvcJGv3t1L4dbryi4q2FxHfIQMlVgU6eE=;EntityPath=exemplo"
};

 const message = {
      topic: "exemplo",
      message: { text: "this is a message" }
   };

  send(config, message)
      .then(data => console.log("Sucess sending message:", data))
      .catch(err => console.log("Failed to send message:", err));

Consumer

const { consume, retry } = require("queue-novatics");

const config = {
  connection:
    "Endpoint=sb://kafkaexample.servicebus.windows.net/;SharedAccessKeyName=kafkaexample;SharedAccessKey=xIVvZp6OHCBvcJGv3t1L4dbryi4q2FxHfIQMlVgU6eE=;EntityPath=exemplo"
};

consume(config, "exemplo", processMessage);

const processMessage = message => {
    const random = Math.floor(Math.random() * 11);
    if (random > 9) {
      console.log("Sucess in process message");
    } else {
      console.log("Failed to process message, send messaage to topic");
      retry(config, message);
    }
}