@councilbox/liebre v2.2305.0

horus-liebre

Usage

import RabbitStore from 'liebre';


const config = {
	user: '****',
	password: '****',
	host: '***.***.***.***',
	port: *****,

	PREFIX: ,
	EXCHANGE: 'v1',
	EXCHANGE_TYPE: 'direct',
	ERRORS: 'errors'
    prefix: 'horus.liebre',
    exchange:'v1',
    errorExchange: 'errors',
    exchangeType: 'direct',
    maxRetries: 15,
    sleepSecondsOnRetry: 5,
    autoAck: false,
	prefetch: process.env.RABBITMQ_CHANNEL_PREFETCH || 20,

};
const PROCESSING_QUEUES = [
	'email.send.one',
	'email.send.many',
	'track.store.mailgun',
	'evidence.create',
	'evidence.create.email',
	'evidence.create.track'
];

async function run() {
	const rabbitStore = new RabbitStore(config);
	await rabbitStore.connectRabbitMq();
	await rabbitStore.createQueue({ queueName });
	console.log('CONNNECTED');


	const callback = msg => {
		console.log(`- Received ${JSON.stringify(msg)}`);
		console.log('sending one');
	};
	const producer = new Producer(rabbitStore);
	const consumer = new Consumer(rabbitStore, queueName);
	producer.publish(queueName, { msg: 'Hello Liebre!' }, '1');
	consumer.consume(queueName, callback);
}

run().then(() => {
	console.log('END');
});