zmq_proxy

This module’s scope is to mediate communication between ZeroMQ clients.

class tuna.zeromq.zmq_proxy.zmq_proxy[source]

This class’ responsibility is to setup a ZeroMQ proxy and mediate message passing between its clients. It binds to port 5000.

check_ACK(ack_msg)[source]

This method’s goal is to verify that the input ZeroMQ message contains the string “ACK”.

Parameters:

  • ack_msg : (byte) string
close()[source]

This method’s goal is to gracefully shutdown the ZeroMQ proxy.

run()[source]

This method’s goal is to orchestrate incoming messages. It will run in loop, listening to messages and dispatching them as appropriated.

Note to developers: destination_call_table is a dictionary associating target strings with the functions to be run. The services responsible for a given target can be changed here without changing the clients.