orangeqs.juice.messaging.zmq._proxy

ZMQ proxy for pub/sub messaging.

Module Contents

Classes

ZMQProxy

ZMQ proxy for pub/sub messaging.

API

class orangeqs.juice.messaging.zmq._proxy.ZMQProxy(pub_uri: str, sub_uri: str, on_message: collections.abc.Callable[[bytes], None] | None = None)

ZMQ proxy for pub/sub messaging.

async run() → None

Run ZMQ proxy for pub/sub messaging.

Runs indefinitely until an exception is encountered or the process is interrupted.