View all node-resque analysis

How to use the node-resque.Queue function in node-resque

To help you get started, we’ve selected a few node-resque examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

StellarFw / stellar / src / satellites / resque.ts View on Github

private async startQueue() {
    this.queue = new NodeResque.Queue(
      {
        connection: this.connectionDetails,
      },
      this.api.tasks.jobs,
    );

    this.queue.on("error", error =>
      this.api.log(error, LogLevel.Error, "[api.resque.scheduler]"),
    );

    await this.queue.connect();
  }

metricio / metricio / lib / queue.js View on Github

export default jobs => {
  const queue = new NodeResque.Queue({ connection: storage.resqueConfig }, jobs);

  queue.on('error', error => {
    logger('error', 'queue: error -> ', error);
  });

  return queue;
};