NATSEventBridge

NATSEventBridge publishes events to a NATS subject and subscribes to the same subject for inbound forwarding.

Go support

Go
Rust

NATSEventBridge 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 NATS extra (recommended):

pip install "abxbus[nats]"

Equivalent direct dependency install:

pip install nats-py

Install the NATS client package:

npm install abxbus nats

This bridge is Node.js-only.

// NATSEventBridge 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

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

Python
TypeScript
Go
Rust

from abxbus.bridges import NATSEventBridge

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

import { NATSEventBridge } from 'abxbus/bridges'

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

// NATSEventBridge 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 NATSEventBridge

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

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

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

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

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

// NATSEventBridge 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 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.

Getting Started

Features

API Reference

Concurrency Control

Integrations

Further Reading

NATSEventBridge

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