New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

exp-amqp-connection

Package Overview
Dependencies
Maintainers
18
Versions
58
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

exp-amqp-connection - npm Package Compare versions

Comparing version

3.3.0
to
3.3.3-beta-1

14

index.js

@@ -15,3 +15,3 @@ "use strict";

// eslint-disable-next-line no-console
error: console.log
error: console.log,
};

@@ -28,3 +28,3 @@

logger: dummyLogger,
configKey: "default"
configKey: "default",
};

@@ -63,3 +63,3 @@

if (bootstrapErr) return; // Ok to ignore, emitted as error in doBootstrap()
const routingKeys = Array.isArray(routingKeyOrKeys) ? routingKeyOrKeys : [routingKeyOrKeys];
const routingKeys = Array.isArray(routingKeyOrKeys) ? routingKeyOrKeys : [ routingKeyOrKeys ];
const subChannel = bootstrapRes.subChannel;

@@ -71,3 +71,3 @@ subChannel.prefetch(behaviour.prefetch);

exclusive: !queue,
arguments: Object.assign(!queue ? { "x-expires": TMP_Q_TTL } : {}, behaviour.queueArguments)
arguments: Object.assign(!queue ? { "x-expires": TMP_Q_TTL } : {}, behaviour.queueArguments),
};

@@ -152,3 +152,3 @@ const queueName = queue ? queue : `${getProductName()}-${getRandomStr()}`;

setupTasks.push(
(done) => channel.assertExchange(name, "fanout", {durable: true, autoDelete: true}, done)
(done) => channel.assertExchange(name, "fanout", { durable: true, autoDelete: true }, done)
);

@@ -160,4 +160,4 @@ const queueArgs = {

"x-dead-letter-exchange": behaviour.exchange,
"x-message-ttl": delay
}
"x-message-ttl": delay,
},
};

@@ -164,0 +164,0 @@ setupTasks.push((done) => channel.assertQueue(name, queueArgs, done));

4

lib/bootstrap.js

@@ -76,3 +76,3 @@ "use strict";

const createSubChannel = conn.createChannel.bind(conn);
async.series([createPubChannel, createSubChannel], (channelErr, newChannels) => {
async.series([ createPubChannel, createSubChannel ], (channelErr, newChannels) => {
if (channelErr) {

@@ -83,3 +83,3 @@ savedConns[behaviour.configKey] = null;

}
const [pubChannel, subChannel] = newChannels;
const [ pubChannel, subChannel ] = newChannels;
const handle = { connection: conn, pubChannel, subChannel, behaviour };

@@ -86,0 +86,0 @@ savedConns[behaviour.configKey] = handle;

6

lib/transform.js

@@ -9,3 +9,3 @@ "use strict";

props: meta,
buffer: {}
buffer: {},
};

@@ -34,4 +34,4 @@

module.exports = {
encode: encode,
decode: decode
encode,
decode,
};

7

package.json

@@ -10,3 +10,3 @@ {

],
"version": "3.3.0",
"version": "3.3.3-beta-1",
"scripts": {

@@ -24,3 +24,3 @@ "test": "mocha",

"dependencies": {
"amqplib": "^0.8.0",
"amqplib": "^0.10.2",
"async": "^3.2.2"

@@ -30,3 +30,4 @@ },

"chai": "^4.3.4",
"eslint": "^8.1.0",
"eslint": "^8.8.0",
"eslint-config-exp": "^0.0.9",
"got": "^11.8.2",

@@ -33,0 +34,0 @@ "mocha": "^9.1.3",