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