Registry / messaging / seneca-redis-queue-transport

seneca-redis-queue-transport

library0.3.0jsnpmunverified

A Seneca.js transport plugin that enables micro-service message passing via Redis list-based queues. Current stable version 0.3.0, tested on Seneca 0.7 and 0.8. Key differentiator: provides a simple queue-based alternative to direct client/listen patterns, using Redis lists for message buffering. Release cadence: low, last release 2016. For older Node.js versions (0.10, 0.12, 4, 5).

messaging

npm install seneca-redis-queue-transport

github ↗package ↗homepage ↗

INSTALL

IMPORT

SIG · SENECA-REDIS-QUEUE

seneca-redis-queue-transport

messagingjavascriptv0.3.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.

seneca-redis-queue-transport

✓ require('seneca')()

✗ require('seneca-redis-queue-transport')

This module is a Seneca plugin; you use it by calling .use('redis-queue-transport') on a Seneca instance, not by requiring the module directly.

client

✓ seneca.client({type:'redis-queue',pin:'...'})

✗ seneca.client({type:'redis',pin:'...'})

The transport type must be 'redis-queue', not just 'redis'.

listen

✓ seneca.listen({type:'redis-queue',pin:'...'})

✗ seneca.listen({transport:'redis-queue',pin:'...'})

The listen method expects 'type' in the options, not 'transport'.

Shows basic usage: load the plugin, define an action, and configure client/listen with redis-queue transport for micro-service messaging.

const Seneca = require('seneca') const seneca = Seneca() seneca.use('redis-queue-transport') seneca.add('foo:two', function(args, done) { done(null, {bar: args.bar}) }) seneca.client({type:'redis-queue', pin:'foo:one,bar:*'}) seneca.listen({type:'redis-queue', pin:'foo:two,bar:*'}) // In another process: const seneca2 = Seneca() seneca2.use('redis-queue-transport') seneca2.client({type:'redis-queue', pin:'foo:two,bar:*'}) seneca2.act('foo:two,bar:baz', console.log) // Output: {bar: 'baz'}

Debug

Known issues

deprecatedThis package is deprecated and no longer maintained. Seneca 0.7 and 0.8 are outdated.

fix

Consider upgrading to Seneca 3.x and using the built-in transport or a maintained alternative.

affects: *

gotchaRequires a running Redis server at default localhost:6379. No authentication or TLS support.

fix

Ensure Redis is installed and running with appropriate configuration.

affects: *

gotchaPin patterns must be comma-separated. A common mistake is using spaces or colon incorrectly.

fix

Use pin:'foo:one,bar:*' not 'foo:one, bar:*' or 'foo:one;bar:*'.

affects: *

Errors

Common errors & fixes

Error: Cannot find module 'seneca-redis-queue-transport'

The module is not installed or the require path is incorrect.

fix

Run 'npm install seneca-redis-queue-transport' and use .use('redis-queue-transport') not require('seneca-redis-queue-transport').

TypeError: seneca.client is not a function

Calling client method before loading the transport plugin or before Seneca is initialized.

fix

Ensure seneca.use('redis-queue-transport') is called before .client() or .listen().

ReplyError: ERR wrong number of arguments for 'lpush' command

Redis connection issue or incompatible Redis version.

fix

Check Redis server version (>=2.6.0) and network connectivity. The plugin uses LPUSH, so Redis must support it.

Upgrade

Version history

0.3.0latest on npm

Audit

Dependencies

No dependency data recorded yet.

Agent activity

15 hits · last 30 days

node

OpenAI (training)

Resources

githubgit://github.com/iantocristian/seneca-redis-queue-transport ↗

packageseneca-redis-queue-transport ↗

homepagehttps://github.com/senecajs/seneca-redis-queue-transport ↗