RedisEventBridge

RedisEventBridge publishes event payloads to a Redis channel and subscribes for inbound events on the same channel.

Go support

Go
Rust

RedisEventBridge is not implemented in abxbus-go yet. Use JSONLEventBridge for the currently supported Go bridge.

// Not implemented in the Rust crate yet.
// Use typed event JSON serialization with an external transport for now.

Optional dependencies

Python
TypeScript
Go
Rust

Install the Redis extra (recommended):

pip install "abxbus[redis]"

Equivalent direct dependency install:

pip install redis

Install the Redis client package:

npm install abxbus ioredis

This bridge is Node.js-only.

// RedisEventBridge is not implemented in abxbus-go yet.
// Use JSONLEventBridge for the currently supported Go bridge.

// Not implemented in the Rust crate yet.
// Use typed events plus EventBus JSON serialization with an external transport for now.

Constructor params

redis_url: redis URL in the form redis://user:pass@host:6379/<db>/<optional_channel>
channel: optional channel override (defaults to URL channel segment or abxbus_events)
name: optional bridge label

Python
TypeScript
Go
Rust

from abxbus.bridges import RedisEventBridge

bridge = RedisEventBridge(
    'redis://user:pass@localhost:6379/1/abxbus_events',
    name='RedisBridge',
)

import { RedisEventBridge } from 'abxbus/bridges'

const bridge = new RedisEventBridge(
  'redis://user:pass@localhost:6379/1/abxbus_events',
  undefined,
  'RedisBridge'
)

// RedisEventBridge is not implemented in abxbus-go yet.
// Use JSONLEventBridge for Go process-to-process bridge tests and deployments.

// Not implemented in the Rust crate yet.
// Use typed events plus EventBus JSON serialization with an external transport for now.

Setup with a bus

Python
TypeScript
Go
Rust

from abxbus import EventBus
from abxbus.bridges import RedisEventBridge

bus = EventBus('AppBus')
bridge = RedisEventBridge('redis://localhost:6379/0/abxbus_events')

bus.on('*', bridge.emit)
bridge.on('*', bus.emit)

import { EventBus } from 'abxbus'
import { RedisEventBridge } from 'abxbus/bridges'

const bus = new EventBus('AppBus')
const bridge = new RedisEventBridge('redis://localhost:6379/0/abxbus_events')

bus.on('*', bridge.emit)
bridge.on('*', bus.emit)

// RedisEventBridge is not implemented in abxbus-go yet.
// Use JSONLEventBridge for Go process-to-process bridge tests and deployments.

// Not implemented in the Rust crate yet.
// Use typed events plus EventBus JSON serialization with an external transport for now.

Behavior

emit(...) publishes serialized event JSON to the configured Redis channel.
on(...) subscribes handlers for inbound messages and auto-starts the Redis subscriber.
Incoming messages are parsed into events, reset, then emitted on the bridge’s internal bus.
close() unsubscribes and closes Redis clients.
Runtime requirements: Python needs redis (redis.asyncio), TypeScript needs ioredis and Node.js.

Getting Started

Features

API Reference

Concurrency Control

Integrations

Further Reading

RedisEventBridge

Go support

Optional dependencies

Constructor params

Setup with a bus

Behavior

​Go support

​Optional dependencies

​Constructor params

​Setup with a bus

​Behavior

Go support

Optional dependencies

Constructor params

Setup with a bus

Behavior