Function main

examples/simple-queue.js:10–30

()

*/

function main() {
	const queuename = "testqueue";

	// create a queue
	rsmq.createQueue({ qname: queuename }, (err) => {
		if (err) {
			// if the error is `queueExists` we can keep going as it tells us that the queue is already there
			if (err.name !== "queueExists") {
				console.error(err);
				return;
			} else {
				console.log("queue exists.. resuming..");
			}
		}

		// start sending messages every 2 seconds
		sendMessageLoop(queuename);
		// start checking for messages every 500ms
		receiveMessageLoop(queuename);
	});
}
main();

function sendMessageLoop(queuename) {