@polymathnetwork/launchpad-rabbitmq v1.3.1

launchpad-rabbitmq

Setup code:

rabbitmq.initialize({
  url: RABBITMQ_URL,
  retryDelay: RETRY_DELAY,
  maxRetries: MAX_RETRIES,
  reconnectDelay: RABBITMQ_RECONNECT_TIMEOUT,
});

await publisher.initialize();
await consumer.initialize();

// Start rabbitMQ consumers
await consumer.startConsumer(QUEUE_NAME, queueMsgProcessorCallBackFun);

To push message to publisher just do any where in code:

import { publisher } from '@polymathnetwork/launchpad-rabbitmq';

const { ack } = await publisher.pushMessage(queueName, message)