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