Registry / messaging / integreat-transporter-bull

integreat-transporter-bull

library1.4.0jsnpmunverified

A Redis-backed Bull queue transporter for the Integreat message flow system. Current stable version is 1.4.0, with an active release cadence. It bridges Integreat actions to Bull job queues, supporting sub-queues, concurrency control, and Redis connection options. Differentiators include tight integration with Integreat's auth and endpoint model, support for reusing existing Bull queues, and automated concurrency limits across sub-queues. Requires Node >=18 and Integreat v1.0.

messaging

npm install integreat-transporter-bull

github ↗package ↗homepage ↗

INSTALL

IMPORT

SIG · INTEGREAT-TRANSPOR

integreat-transporter-bull

messagingjavascriptv1.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.

bullTransporter

✓ import bullTransporter from 'integreat-transporter-bull'

✗ const bullTransporter = require('integreat-transporter-bull')

Default export is a function that returns a transporter object. CommonJS require may not work with ESM-only packages; check your environment.

Shows setting up Integreat with the bull transporter, defining a source endpoint, and dispatching an action.

import Integreat from 'integreat' import bullTransporter from 'integreat-transporter-bull' const defs = { sources: [{ id: 'store', transporter: 'bull', auth: true, endpoints: [{ options: { queueId: 'my-queue', maxConcurrency: 5 } }] }] } const great = Integreat.create(defs, { transporters: { bull: bullTransporter() } }) await great.dispatch({ type: 'MY_ACTION', payload: { message: 'Hello' } })

Debug

Known issues

breakingThe package now requires Node >= 18 and Integreat v1.0.

fix

Upgrade Node and Integreat to meet minimum versions.

affects: >=1.0

deprecatedSetting redis credentials via 'auth' prop on the service definition is deprecated; use the 'redis' option object with 'key' and 'secret' or a URI.

fix

Move authentication to the redis options: options: { redis: { key: 'username', secret: 'password' } }

affects: >=1.0

gotchaWhen using sub-queues, only the maxConcurrency from the first sub-queue applies; all sub-queues of the same main queue share a single handler.

fix

Set maxConcurrency only on the first sub-queue definition; other sub-queues will inherit it.

affects: >=1.0

gotchaDo not set 'auth' to a falsy value (like undefined) if you need authentication; use 'auth: true' to indicate no authentication needed.

fix

Set auth: true explicitly when no Redis auth is required.

affects: >=1.0

Errors

Common errors & fixes

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

Package not installed or import path incorrect.

fix

Run 'npm install integreat-transporter-bull' and ensure you use the correct import statement: 'import bullTransporter from 'integreat-transporter-bull''

TypeError: bullTransporter is not a function

Using default import incorrectly or the module was not imported as a function.

fix

Use 'import bullTransporter from 'integreat-transporter-bull'' and then call bullTransporter() to create the transporter object.

Error: connect ECONNREFUSED 127.0.0.1:6379

Redis server not running or not accessible at default host/port.

fix

Start a Redis server or configure the 'redis' option with correct host and port, e.g., { redis: 'redis://myhost:6380' }

Upgrade

Version history

1.4.0latest on npm

Audit

Dependencies

integreatrequiredPeer dependency; the transporter is used to extend Integreat with Bull queue functionality.

bullrequiredUnderlying queueing library; the transporter wraps Bull for Integreat.

Agent activity

13 hits · last 30 days

node

OpenAI (training)

Resources

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

packageintegreat-transporter-bull ↗

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