lionmq-clientside
v1.1.4
Published
## Installing
Downloads
54
Readme
LIONMQ_client
Installing
npm install lionmq-clientside
Illustration
lionmq-clientside
provides four basic functions for connecting to the lionmq
server and performing various operations."
Initialization
Please enter the IP address of the host where LionMQ is running in the host field, and in the port field, enter the port number your host is listening on, which is usually 80 for HTTP.
import { MessageQueueClient } from "lionmq-clientside";
const host = "your connection host";
const client = new MessageQueueClient(host, "Your connection port number");
Enqueue
Please first enter the channel name you wish to send to. Then enter the message type for the message queue. Finally, attach the source interface in the payload to send the message you want to LionMQ.
client.enqueueMessage("Enter your channel name", {
messageType: "text",
payload: `Message:${Math.random() + 10}`,
});
Dequeue & Acknowledgement
Please first enter the channel name you wish to send to. Then enter the message type for the message queue. Finally, attach the source interface in the payload to send the message you want to LionMQ.
try {
const message = await client.dequeueMessage("Your channel name", true);
const parsedMessage = JSON.parse(message);
console.log(`Processing message: ${parsedMessage.messageID}`);
await client.ackMessage("Your channel name", parsedMessage.messageID);
} catch (error) {
console.error(`Error processing message: ${error.message}`);
}
Cluster Nodes Setting
In the cluster node, enter the IP addresses of all the servers you wish to be primary nodes in the first array, and enter the IP addresses of the servers you wish to be backup nodes in the second array. Instances at the same index number in the two different arrays will be bound together as primary and backup nodes.
client.setNodes(
["Enter your lionmq server ip that you want to use for primary node"],
["Enter your lionmq server ip that you want to use for backup node"]
);
ex.
(["http://localhost:3000","http://localhost:3001","http://localhost:3002"], ["http://localhost:3003","http://localhost:3004","http://localhost:3005"])
Now http://localhost:3003 is the backup node of http://localhost:3000