***
title: "JobQueue"
generated: true
---------------
A JobQueue is used to process [Job](/current/core/reference/typescript-api/job-queue/job#job)s. A job is added to the queue via the
`.add()` method, and the configured [JobQueueStrategy](/current/core/reference/typescript-api/job-queue/job-queue-strategy#jobqueuestrategy) will check for new jobs and process each
according to the defined `process` function.
*Note*: JobQueue instances should not be directly instantiated. Rather, the
[JobQueueService](/current/core/reference/typescript-api/job-queue/job-queue-service#jobqueueservice) `createQueue()` method should be used (see that service
for example usage).
```ts title="Signature"
class JobQueue = object> {
name: string
started: boolean
constructor(options: CreateQueueOptions, jobQueueStrategy: JobQueueStrategy, jobBufferService: JobBufferService)
add(data: Data, options?: JobOptions) => Promise>;
}
```
### name
\
### started
\
### add
\
) => Promise<SubscribableJob>`} />
Adds a new [Job](/current/core/reference/typescript-api/job-queue/job#job) to the queue. The resolved [SubscribableJob](/current/core/reference/typescript-api/job-queue/subscribable-job#subscribablejob) allows the
calling code to subscribe to updates to the Job:
*Example*
```ts
const job = await this.myQueue.add({ intervalMs, shouldFail }, { retries: 2 });
return job.updates().pipe(
map(update => {
// The returned Observable will emit a value for every update to the job
// such as when the `progress` or `status` value changes.
Logger.info(`Job ${update.id}: progress: ${update.progress}`);
if (update.state === JobState.COMPLETED) {
Logger.info(`COMPLETED ${update.id}: ${update.result}`);
}
return update.result;
}),
catchError(err => of(err.message)),
);
```
Alternatively, if you aren't interested in the intermediate
`progress` changes, you can convert to a Promise like this:
*Example*
```ts
const job = await this.myQueue.add({ intervalMs, shouldFail }, { retries: 2 });
return job.updates().toPromise()
.then(update => update.result),
.catch(err => err.message);
```