| 1234567891011121314151617181920212223242526272829303132333435363738 |
- import { __rest } from "tslib";
- import { QueueBase } from './queue-base';
- /**
- * The QueueEventsProducer class is used for publishing custom events.
- */
- export class QueueEventsProducer extends QueueBase {
- constructor(name, opts = {
- connection: {},
- }, Connection) {
- super(name, Object.assign({ blockingConnection: false }, opts), Connection);
- this.opts = opts;
- }
- /**
- * Publish custom event to be processed in QueueEvents.
- * @param argsObj - Event payload
- * @param maxEvents - Max quantity of events to be saved
- */
- async publishEvent(argsObj, maxEvents = 1000) {
- const client = await this.client;
- const key = this.keys.events;
- const { eventName } = argsObj, restArgs = __rest(argsObj, ["eventName"]);
- const args = ['MAXLEN', '~', maxEvents, '*', 'event', eventName];
- for (const [key, value] of Object.entries(restArgs)) {
- args.push(key, value);
- }
- await client.xadd(key, ...args);
- }
- /**
- * Closes the connection and returns a promise that resolves when the connection is closed.
- */
- async close() {
- if (!this.closing) {
- this.closing = this.connection.close();
- }
- await this.closing;
- }
- }
- //# sourceMappingURL=queue-events-producer.js.map
|