Use localhost for reply and request

This commit is contained in:
Nicolas Mowen 2024-01-11 16:00:35 -07:00
parent 0deea0baf2
commit 8cf021630e

View File

@ -19,7 +19,7 @@ class InterProcessCommunicator(Communicator):
)
self.context = zmq.Context()
self.socket = self.context.socket(zmq.REP)
self.socket.bind(f"tcp://*:{INTER_PROCESS_COMM_PORT}")
self.socket.bind(f"tcp://127.0.0.1:{INTER_PROCESS_COMM_PORT}")
self.stop_event: MpEvent = mp.Event()
def publish(self, topic: str, payload: str, retain: bool) -> None: