keuss

library2.2.3jsnpmunverified

Enterprise-grade job queue library for Node.js with persistent backends: Redis, MongoDB, or PostgreSQL. Version 2.2.3 supports HA pipelines, bucket processing, and poll/push modes. Differentiators include multiple backend support, high availability, and flexible queue semantics. Released under MIT, with active maintenance.

database

npm install keuss

package ↗homepage ↗

INSTALL

IMPORT

SIG · KEUSS

keuss

databasejavascriptv2.2.3

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

Keuss

✓ import Keuss from 'keuss'

✗ const Keuss = require('keuss')

ESM-only since v2

Queue

✓ import { Queue } from 'keuss'

✗ import Queue from 'keuss'

Named export for Queue class

Pipeline

✓ import { Pipeline } from 'keuss'

✗ import Pipeline from 'keuss'

Named export for Pipeline class

Shows how to create a Redis-backed queue, push a job, and consume with a callback.

import { Queue } from 'keuss'; import { createClient } from 'redis'; const client = createClient({ url: process.env.REDIS_URL ?? 'redis://localhost:6379' }); await client.connect(); const queue = new Queue(client, 'myqueue', { type: 'redis', pollInterval: 1000, }); // Producer await queue.push({ task: 'process', data: { id: 123 } }); // Consumer queue.pop(async (job) => { console.log('Processing:', job.payload); await job.done(); });

Debug

Known issues

breakingv2.0.0 switched to ESM-only, dropping CommonJS require()

fix

Use ESM imports (import Keuss from 'keuss') or downgrade to v1.x

affects: >=2.0.0

deprecatedQueue constructor now expects a client object instead of connection string (deprecated since v2.1)

fix

Pass a pre-connected client (redis, mongodb, or pg) instead of URL string

affects: >=2.1.0

gotchaPipeline requires explicit 'type: redis' or 'type: mongodb' to enable pipeline mode

fix

Set type option to one of the supported backends

affects: >=2.0.0

breakingjob.done() now returns a Promise (async) instead of synchronous confirmation

fix

Use await job.done() or handle promise resolution

affects: >=2.1.0

gotchaPoll interval option defaults to 0 (no polling) in v2; must set pollInterval > 0 for automatic polling

fix

Explicitly set pollInterval (e.g., 1000 for 1 second)

affects: >=2.0.0

Errors

Common errors & fixes

Error: Cannot find module 'keuss'

Mixed ESM/CJS or wrong package.json type field

fix

Add "type": "module" to package.json or use .mjs extension

TypeError: queue.push is not a function

Using Queue as default import instead of named import or misconfigured backend

fix

Use import { Queue } from 'keuss' instead of import Queue from 'keuss'

Error: redis connection closed

Client connection not established before queue creation

fix

Ensure client.connect() is called and awaited before instantiating Queue

Error: job.done is not a function

Deprecated synchronous done() removed in v2.1

fix

Update to job.done() returning promise; use await or .then()

Error: Unsupported backend type: 'redis' may not be installed

Missing backend driver package

fix

Install required driver: npm install redis mongodb pg

Upgrade

Version history

2.2.3latest on npm

Audit

Dependencies

No dependency data recorded yet.

Agent activity

7 hits · last 30 days

node

Resources

packagekeuss ↗

homepagehttps://pepmartinez.codeberg.page/keuss/ ↗