Skip to content

Documentation / @super-line/adapter-zeromq / createZeroMqProxy

Function: createZeroMqProxy()

createZeroMqProxy(options): Promise<ZeroMqProxy>

Defined in: index.ts:213

Run a ZeroMQ XSUB⇄XPUB forwarder — the central broker for mode: 'proxy' adapters. Nodes connect their PUB to frontendUrl and their SUB to backendUrl; the proxy relays every message (and propagates subscriptions back to publishers, so native channel filtering still works through it).

Parameters

options

ZeroMqProxyOptions

Returns

Promise<ZeroMqProxy>

Example

ts
const proxy = await createZeroMqProxy({ frontendUrl: 'tcp://0.0.0.0:5557', backendUrl: 'tcp://0.0.0.0:5558' })

Released under the MIT License.