Method enqueue

src/core/queue.ts:82–103

* - Enqueue a named job (defined in `jobs` to be worked by a worker) * - The job will be added to the `queueName` queue, and that queue will be worked down by available workers assigned to that queue * - args is optional, but should be an array of arguments passed to the job. Order of argument

(q: string, func: string, args: Array<any> = [])

   * - args is optional, but should be an array of arguments passed to the job. Order of arguments is maintained
   */
  async enqueue(q: string, func: string, args: Array<any> = []) {
    args = arrayify(args);
    const job = this.jobs[func];

    const toRun = await RunPlugins(this, "beforeEnqueue", func, q, job, args);
    if (toRun === false) return toRun;

    const response = await this.connection.redis
      .multi()
      .sadd(this.connection.key("queues"), q)
      .rpush(this.connection.key("queue", q), this.encode(q, func, args))
      .exec();

    response?.forEach((res) => {
      if (res[0] !== null) {
        throw res[0];
      }
    });

    await RunPlugins(this, "afterEnqueue", func, q, job, args);
    return toRun;
  }

  /**
   * - In ms, the unix timestamp at which this job is able to start being worked on.