ZmqDistributor

class catkit2.testbed.ZmqDistributor(context, input_port, output_port, callback=None)

Bases: object

Collects messages on a port and re-publish them on another.

This operates on a separate thread after it is started.

contextzmq.Context

A previously-created ZMQ context. All sockets will be created on this context.

input_portinteger

The port number for the incoming log messages.

output_portinteger

The port number for the outgoing log messages.

callbackfunction

A callback to call with each message.

Methods Summary

start()	Start the proxy thread.
stop()	Stop the proxy thread.

Methods Documentation

start()

Start the proxy thread.

stop()

Stop the proxy thread.

This function waits until the thread is actually stopped.