@techloop/amqp-broker
Advanced tools
Comparing version 1.4.4 to 1.4.5
@@ -22,6 +22,6 @@ if (!process.env.RABBITMQ_DSN) { | ||
connection.on("ready", function () { | ||
console.log("Connected to AMQP server") | ||
const exchange = connection.exchange(process.env.EXCHANGE_NAME) | ||
callback(false, connection, exchange) | ||
console.log("Connected to AMQP server"); | ||
const exchange = connection.exchange(process.env.EXCHANGE_NAME, {durable: true, autoDelete: false}); | ||
callback(false, connection, exchange); | ||
}) | ||
} |
{ | ||
"name": "@techloop/amqp-broker", | ||
"version": "1.4.4", | ||
"version": "1.4.5", | ||
"description": "AMQP broker for microservices communication", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
4724