diff --git a/queue/importQueue.ts b/queue/importQueue.ts index 097294c..d2e52d8 100644 --- a/queue/importQueue.ts +++ b/queue/importQueue.ts @@ -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