@techloop/amqp-broker
Advanced tools
Comparing version 1.3.16 to 1.3.17
@@ -23,11 +23,9 @@ if (!process.env.RABBITMQ_DSN) { | ||
console.log("Connected to AMQP server") | ||
const exchange = connection.exchange(process.env.EXCHANGE_NAME) | ||
console.log(exchange); | ||
exchange.on('open', (e) => { | ||
const exchange = connection.exchange(process.env.EXCHANGE_NAME, (e) => { | ||
console.log("exchange is open", e) | ||
console.log("exchange is open", this.exchange) | ||
}) | ||
callback(false, connection, exchange) | ||
}) | ||
} |
@@ -108,3 +108,3 @@ if (!process.env.EXCHANGE_NAME) { | ||
.then(() => { | ||
console.log(`Task ${Task.routingKey} accomplished`) | ||
console.log(`Task ${Task.key} accomplished`) | ||
}) | ||
@@ -118,3 +118,3 @@ .catch(error => { | ||
console.log(data) | ||
console.log(process.env.EXCHANGE_NAM); | ||
console.log(process.env.EXCHANGE_NAME); | ||
@@ -121,0 +121,0 @@ this.exchange.publish(failureRoutingKey, data, { |
{ | ||
"name": "@techloop/amqp-broker", | ||
"version": "1.3.16", | ||
"version": "1.3.17", | ||
"description": "AMQP broker for microservices communication", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 1 instance in 1 package
5227
151