NATSEventBridge

​

Optional dependencies

pip install "bubus[nats]"

pip install nats-py

npm install bubus nats

​

Constructor params

• server: NATS server URL (for example nats://localhost:4222)
• subject: subject name used for publish/subscribe
• name: optional bridge label

from bubus import NATSEventBridge

bridge = NATSEventBridge(
    'nats://localhost:4222',
    'bubus_events',
    name='NatsBridge',
)

import { NATSEventBridge } from 'bubus'

const bridge = new NATSEventBridge(
  'nats://localhost:4222',
  'bubus_events',
  'NatsBridge'
)

​

Setup with a bus

from bubus import EventBus, NATSEventBridge

bus = EventBus('AppBus')
bridge = NATSEventBridge('nats://localhost:4222', 'bubus_events')

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

import { EventBus, NATSEventBridge } from 'bubus'

const bus = new EventBus('AppBus')
const bridge = new NATSEventBridge('nats://localhost:4222', 'bubus_events')

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

​

Behavior

• emit(...) publishes serialized event JSON bytes to the configured subject.
• on(...) registers inbound handlers and auto-starts subscription.
• Inbound messages are decoded, reset, and re-emitted on the internal bus.
• close() drains/closes NATS connections and stops the internal bus.
• Runtime requirements: Python needs nats-py, TypeScript needs nats and Node.js.