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

@rewaa/event-broker

Package Overview
Dependencies
Maintainers
0
Versions
49
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@rewaa/event-broker - npm Package Compare versions

Comparing version

to
6.2.2

16

dist/emitters/emitter.sqns.js

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

on(eventName, listener, options) {
var _a, _b, _c;
var _a, _b, _c, _d, _e, _f;
const topic = this.getTopicFromEventNameAndConsumeOptions(eventName, options);

@@ -524,6 +524,10 @@ const queueName = this.getQueueName(topic);

: (_b = this.options.defaultQueueOptions) === null || _b === void 0 ? void 0 : _b.standard.name) ||
'',
"",
isFifo: this.isConsumerFifo(topic),
batchSize: topic.batchSize || constants_1.DEFAULT_BATCH_SIZE,
visibilityTimeout: topic.visibilityTimeout || constants_1.DEFAULT_VISIBILITY_TIMEOUT,
batchSize: ((_c = topic.consumerGroup) === null || _c === void 0 ? void 0 : _c.batchSize) ||
topic.batchSize ||
constants_1.DEFAULT_BATCH_SIZE,
visibilityTimeout: ((_d = topic.consumerGroup) === null || _d === void 0 ? void 0 : _d.visibilityTimeout) ||
topic.visibilityTimeout ||
constants_1.DEFAULT_VISIBILITY_TIMEOUT,
url: this.getQueueUrl(queueName),

@@ -535,3 +539,3 @@ arn: this.getQueueArn(this.getQueueName(topic)),

allTopics: [topic],
workers: topic.workers,
workers: ((_e = topic.consumerGroup) === null || _e === void 0 ? void 0 : _e.workers) || topic.workers,
};

@@ -541,3 +545,3 @@ this.queues.set(queueName, queue);

else {
(_c = this.queues.get(queueName)) === null || _c === void 0 ? void 0 : _c.allTopics.push(topic);
(_f = this.queues.get(queueName)) === null || _f === void 0 ? void 0 : _f.allTopics.push(topic);
}

@@ -544,0 +548,0 @@ }

{
"name": "@rewaa/event-broker",
"version": "6.2.0",
"version": "6.2.2",
"description": "A broker for all the events that Rewaa will ever produce or consume",

@@ -5,0 +5,0 @@ "main": "dist/index.js",

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet