---
title: "@playstack/nest-queues"
description: "Named NestJS queue injection, typed handler discovery, worker startup, and shutdown lifecycle."
tags: ["package","infrastructure","nestjs","queues","bullmq","workers","free"]
---

{/* package-access:start */}

> **Free.** MIT licensed. Check preview availability before installing. See [package access](/docs/packages#access-policy).

{/* package-access:end */}

`@playstack/nest-queues` binds portable Playstack queues to NestJS dependency injection without hiding the selected provider.

```ts
PlaystackQueuesModule.forRoot({
  app: 'fontstack',
  environment: 'production',
  queues: {
    'font-processing': { driver: processingDriver, worker: processingWorker },
    publishing: { driver: publishingDriver, worker: publishingWorker },
  },
})
```

`@QueueHandler()` discovers existing injectable handlers, and `@InjectPlaystackQueue(name)` selects a stable named queue. An optional worker starts after discovery and closes with the application.

Progress, schedules, cancellation, counts, and bounded inspection remain available through the queue control surface. BullMQ concurrency, locks, stalled-job policy, flows, priorities, and rate limits remain native application options.

{/* package-install:start */}

## Install

After confirming [preview access](/docs/packages#access-policy), install the package at your application's shared Playstack version:

```sh
npm install --save-exact @playstack/nest-queues@0.1.0-beta.1
```

Check the peer requirements below before choosing a runtime or provider.

{/* package-install:end */}

## Existing queues and strict readiness

BullMQ `>=5.16 <7` is supported; selected monitoring integrations retain their own peer restrictions. `assertBullMqRedisNoEviction(queue.client)` is a fail-closed startup/readiness check, distinct from the non-blocking dispatch observer. It fails if the policy is incompatible or cannot be verified.

The optional [Queuebert bridge](/integrations/queuebert) preserves reviewed native queues and processor statistics. Set a per-queue `expectedPrefix` for an existing physical namespace instead of renaming queues. The bridge does not start workers or authorize administrative HTTP. A job/processor migration still needs drain, cutover and rollback decisions.

{/* package-reference:start */}

## API entry points and requirements

Reference snapshot: `@playstack/nest-queues@0.1.0-beta.1`. Import only the entry point your runtime needs. Paths below are relative to the installed package; use **Go to Definition** in your editor to inspect exact parameters, return types and overloads. Do not import the declaration-file paths directly.

| Public entry point | Declaration file |
| --- | --- |
| `@playstack/nest-queues` | `./dist/index.d.ts` |
| `@playstack/nest-queues/testing` | `./dist/testing.d.ts` |
| `@playstack/nest-queues/queuebert` | `./dist/queuebert.d.ts` |
| `@playstack/nest-queues/package.json` | No TypeScript declaration (asset or metadata export). |

Node.js engine requirement: `>=20`. This is not a claim that every entry point works in browsers or Workers.

### Peer dependencies

Keep existing framework versions that satisfy these ranges. Install optional peers only when using the corresponding adapter. The package manager resolves ordinary dependencies separately.

| Peer | Compatible range | When needed |
| --- | --- | --- |
| `@nestjs/common` | `^10.0.0 \|\| ^11.0.0` | Required by the package. |
| `@nestjs/core` | `^10.0.0 \|\| ^11.0.0` | Required by the package. |
| `@playstack/queues` | `0.1.0-beta.1` | Required by the package. |
| `reflect-metadata` | `^0.1.13 \|\| ^0.2.0` | Required by the package. |
| `rxjs` | `^7.0.0` | Required by the package. |

For a complete first program, start with [Getting started](/docs/getting-started). For API lookup and partial-example conventions, see [Reading the reference](/docs/packages#reading-the-reference). Provider failures, lifecycle requirements and application responsibilities remain described in the guide above; types alone do not establish production safety.

{/* package-reference:end */}