Clean ZMQ termination

This commit is contained in:
Anthony Scemama 2020-04-06 00:37:52 +02:00
parent a0e55498da
commit 7239f5a5b8
1 changed files with 3 additions and 1 deletions

View File

@ -885,7 +885,9 @@ let run ~port =
Zmq.Socket.send pair_socket @@ string_of_pub_state Stopped;
Thread.join pub_thread;
Zmq.Socket.close rep_socket
Zmq.Socket.close pair_socket;
Zmq.Socket.close rep_socket;
Zmq.Context.terminate zmq_context