@rewaa/event-broker
Advanced tools
Comparing version
@@ -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
241743
0.2%2051
0.2%