nodejs-utils-rmq

nodejs-utils-rmq

RabbitMQ helper utility for nodeJS

example

const QueueHelper = require(`nodejs-utils-rmq`)

const queueConfig = {
	QUEUE: {
		CHECK_INTERVAL: 300000,
		CONNECTION_OPTIONS: {
			host: `some-host`
		},
		ASSERT_OPTIONS: {
			durable: true
		}
	},
	MY_QUEUE: {
		CONSUME_OPTIONS: {
			noAck: false
		},
		SEND_OPTIONS: {
			persistent: true,
			content_type: `application/json`
		},
		NAME: `myQueue`,
	},
}

const rmq = new QueueHelper() // new QueueHelper(customLogger like log4js)
const sendMessage = () => {
	rmq.sendRMQMessage(queueConfig.MY_QUEUE.NAME,
		{id: `test id`, data: `test data`},
		queueConfig.MY_QUEUE.SEND_OPTIONS)
		.then(res => console.log(res))
		.catch(err => console.error(err))
}
const processMessage = msg => {
	// do something
	console.log(`Process message...`)

	let msgId = `noId`

	if (`correlationId` in msg.properties) {
		msgId = msg.properties.correlationId
		console.log(`Incoming message: ${msgId}`)
	}

	rmq.sendRMQack(msg)
}
const params = {
	requiredQueues: [queueConfig.MY_QUEUE.NAME],
	queue: {
		connectionOptions: queueConfig.QUEUE.CONNECTION_OPTIONS,
		assertOptions: queueConfig.QUEUE.ASSERT_OPTIONS
	},
	requiredListeners: [{
		name: queueConfig.MY_QUEUE.NAME,
		options: queueConfig.MY_QUEUE.CONSUME_OPTIONS,
		worker: processMessage,
	}],
	customChannelReadyListener: () => sendMessage()
}

rmq.setRMQData(params)
	.then(() => console.log(`Ready !`))
	.catch(err => console.error(err))

rmq.setCheckQueueInterval(queueConfig.QUEUE.CHECK_INTERVAL)