Reference

Queue API Reference

interface Job {
  name: string;
  data: any;
  opts?: JobOpts;
}

interface JobOpts {
  attempts?: number;
  backoff?: {
    type: "exponential" | "linear",
    delay: number // Time in milliseconds
  };
  delay?: number; // Milliseconds
  priority?: number; // Value between 1 and 2_097_152
  lifo?: boolean;
  jobId?: string;
}

interface JobJson {
    id: string;
    data: any;
    opts: JobOpts;
    progress?: number | object;
    returnvalue?: string;
    failedReason?: string;
    stacktrace?: string[];
    attemptsMade: number;
    delay: number;
    timestamp: number;
    processedOn?: number;
    finishedOn?: number;
    queueQualifiedName: string;
}

Add jobs

POST /queues/:queue-name/jobs

Adds one or more jobs to a given queue.

Headers

Name	Value
Content-Type	application/json
Authorization	Bearer <token>

Body

The body must include an array of jobs with the following structure:

Name	Type	Description
name	string	Name of the job
data	any	Arbitrary data to pass to the job processor.
opts	JobOpts	Job options

Response

200

[{
  "id": string,
  "name": string,
  "data": {},
  "opts": JobOpts,
  ...
}]

400

Get Jobs

GET /queues/:queue-name/jobs

Get jobs in a queue in pages and filtered according to their statuses.

Query Params

Name	Default	Description
statuses	all	comma separated lists of valid statuses ("waiting", "delayed", "prioritized", "completed" or "failed"
start	0	offset on where the returned page should start
length	10	Maximum number of job to return in the page

Headers

Name	Value
Content-Type	application/json
Authorization	Bearer <token>

Response

200

{
  "counts"; { [status: string]: number },
  "jobs": JobJson[],
  "start": number,
  "length": number
}

400

Get Job

GET /queues/:queue-name/jobs/job-id

<Description of the endpoint>

Headers

Name	Value
Content-Type	application/json
Authorization	Bearer <token>

Response

200

JobJson

400