Registry / messaging / integreat-queue-bull

integreat-queue-bull

library0.4.0jsnpmunverified

Redis-backed queue adapter for Integreat based on Bull. Version 0.4.0 is the latest, targeting Integreat <=0.7. This package is a legacy implementation; for Integreat >=0.8 use integreat-transporter-bull. It provides a queue interface using Bull and Redis for message processing. Alternative Bee-Queue implementation available as integreat-queue-redis. Requires Node >=18.0. No active development; users should migrate to the transporter variant.

messaging

npm install integreat-queue-bull

github ↗package ↗homepage ↗

INSTALL

IMPORT

SIG · INTEGREAT-QUEUE-BU

integreat-queue-bull

messagingjavascriptv0.4.0

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.

default (queue factory function)

✓ import integreatQueueBull from 'integreat-queue-bull'

✗ const { integreatQueueBull } = require('integreat-queue-bull')

ESM default export, not a named export. Also available as CommonJS require() for Node <18.

Creates a Bull-based Redis queue with a URI, connects, enqueues a message, and registers a processor.

import integreatQueueBull from 'integreat-queue-bull'; const queue = integreatQueueBull({ uri: process.env.REDIS_URL ?? 'redis://localhost:6379', prefix: 'myapp', }); queue.on('error', (err) => console.error(err)); async function main() { await queue.connect(); await queue.enqueue({ type: 'greet', payload: { name: 'World' } }); queue.process(async (msg) => { console.log(`Hello ${msg.payload.name}`); }); } main();

Debug

Known issues

deprecatedThis package is legacy and will not receive updates. Use integreat-transporter-bull for Integreat >=0.8.

fix

Replace integreat-queue-bull with @integreat/transporter-bull and update imports accordingly.

affects: >=0.4.0

breakingRequires Node >=18.0; older versions are not supported.

fix

Upgrade Node.js to version 18 or later.

affects: >=0.4.0

gotchaThe queue expects a 'uri' option (Redis connection string), not separate host/port.

fix

Use a single 'uri' string like 'redis://user:pass@host:6379'.

affects: >=0.1.0

Errors

Common errors & fixes

Error: Cannot find module 'integreat-queue-bull'

Package not installed or not in node_modules.

fix

Run 'npm install integreat-queue-bull' and ensure you are not using a different package name.

TypeError: integreatQueueBull is not a function

Importing as named export instead of default.

fix

Use 'import integreatQueueBull from 'integreat-queue-bull'' or 'const integreatQueueBull = require('integreat-queue-bull')'.

Error: Redis connection to 127.0.0.1:6379 failed - connect ECONNREFUSED

Redis server not running or URI incorrect.

fix

Start Redis server or provide correct URI via REDIS_URL environment variable.

Upgrade

Version history

0.4.0latest on npm

Audit

Dependencies

bullrequiredQueue backend for Redis

integreatrequiredPeer dependency for Integreat integration

Agent activity

11 hits · last 30 days

node

OpenAI (training)

Resources

githubhttps://github.com/integreat-io/integreat-queue-bull ↗

packageintegreat-queue-bull ↗

homepagehttps://github.com/integreat-io/integreat-queue-bull#readme ↗