✏️ Added a reference to DOCKER_HOST for the rabbitMQ connection string

This commit is contained in:
2021-10-21 14:49:17 -07:00
parent 9d5d08d504
commit d50785b007

View File

@@ -1,7 +1,7 @@
import { logger } from "../utils/logger.utils";
//RabbitMQ
const amqp = require("amqplib/callback_api");
const rabbitUrl = "amqp://localhost";
const rabbitUrl = process.env.DOCKER_HOST ? `amqp://${process.env.DOCKER_HOST}` : `amqp://localhost`;
export const sendToRabbitMQ = (queueName, data) => {
// connect to local rabbitmq instance