inter-cluster-queue-manager-client
v1.1.9
Published
This project was implemented to solve the poblem of data communication between applications/replicas in a cluster.
Downloads
2
Maintainers
Readme
INTER-CLUSTER-QUEUE-MANAGER-CLIENT
This is a simple NodeJsClient to consume and publish from interClusterQueueManagerServer
How to use It ?
Initialize the consumer :
const consumer = new EventConsumer('http://127.0.0.1:3600',{});
Declere your CallBacks on events:
consumer.on("error",(err)=>{
console.error(err)
})
consumer.on("open",(e)=>{
console.log(`Connection succussifly established`,e)
})
consumer.on("message",(msg)=>{
// @example : {"type":"message","data":{"timestamp":"2023-02-18T11:24:44.679Z","event":{"user":"10"},"topic":"deals"},"lastEventId":"","origin":"http://127.0.0.1:3600"}
console.log('new messsage',msg)
})
Now you can start consuming from your topics:
consumer.startConsumeFromTopics(["deals","notifications","etc..."]);
How to use publisher
The publisher is used to send event to topics
Initialize the publisher :
const publisher = new EventPublisher('http://127.0.0.1:3600');
start to publish your events :
try {
await publisher.publish("deals", {
user: +(Math.random() * 1000).toFixed(),
status: "open",
extra: {
boh: true
}
})
console.log("Ok");
} catch (err) {
console.error("Error while sending event")
}