HTTPEventBridge

HTTPEventBridge forwards event JSON over HTTP and can optionally expose an inbound HTTP listener.

Go support

Go
Rust

HTTPEventBridge 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.

Constructor params

send_to: optional outbound endpoint (http:// or https://)
listen_on: optional inbound endpoint (http:// only)
name: optional bridge label

Python
TypeScript
Go
Rust

from abxbus.bridges import HTTPEventBridge

bridge = HTTPEventBridge(
    send_to='https://peer.example.com/abxbus_events',
    listen_on='http://0.0.0.0:8002/abxbus_events',
    name='HttpBridge',
)

import { HTTPEventBridge } from 'abxbus/bridges'

const bridge = new HTTPEventBridge({
  send_to: 'https://peer.example.com/abxbus_events',
  listen_on: 'http://0.0.0.0:8002/abxbus_events',
  name: 'HttpBridge',
})

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

bus = EventBus('AppBus')
bridge = HTTPEventBridge(
    send_to='https://peer.example.com/abxbus_events',
    listen_on='http://0.0.0.0:8002/abxbus_events',
)

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

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

const bus = new EventBus('AppBus')
const bridge = new HTTPEventBridge({
  send_to: 'https://peer.example.com/abxbus_events',
  listen_on: 'http://0.0.0.0:8002/abxbus_events',
})

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

// HTTPEventBridge 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(...) serializes an event and sends a POST request to send_to.
on(...) registers handlers on the bridge’s internal inbound bus and auto-starts the listener when needed.
Inbound payloads are parsed back into BaseEvent, reset to pending state, then emitted on the internal bus.
close() shuts down listener/server resources and the internal bus.
In TypeScript, listener mode (listen_on) is supported in Node.js runtimes.

Getting Started

Features

API Reference

Concurrency Control

Integrations

Further Reading

HTTPEventBridge

Go support

Constructor params

Setup with a bus

Behavior

​Go support

​Constructor params

​Setup with a bus

​Behavior

Go support

Constructor params

Setup with a bus

Behavior