Method startProcessingQueues

lib/core/queueHandler.js:215–223

()

  }

  async startProcessingQueues() {
    for (const item of this.queues) {
      const { queue, plugin } = item;
      // For each queue, set up the processor that handles messages
      queue.process(message =>
        Promise.resolve(plugin.processMessage(message, this))
      );
    }
  }

  async drainAllQueues() {
    const queues = this.queues;