Overview

Documentation Index

Fetch the complete documentation index at: https://abxbus.archivebox.io/llms.txt

Use this file to discover all available pages before exploring further.

• emit(...) for outbound forwarding
• on(...) for inbound subscription
• start() and close() for lifecycle control

​

Quick setup

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)

​

Bridge pages

• HTTPEventBridge
• SocketEventBridge
• RedisEventBridge
• NATSEventBridge
• PostgresEventBridge
• JSONLEventBridge
• SQLiteEventBridge
• TachyonEventBridge