pub fn send_msg(&self, peer: &str, msg: &Msg) {
        let client = &self.ctxt.socket(zmq::REQ).unwrap();
        client.connect(peer).expect("Could not connect to peer");
        client.send(msg.to_msg().as_str(), 0).unwrap();
        client.recv_msg(0).unwrap(); // Wait for ack...
    }
/// send a message to a particular peer.
send a message to a particular peer.
send a message to a particular peer .
pub fn send_msg(&self, peer: &str, msg: &Msg) {
        let client = &self.ctxt.socket(zmq::REQ).unwrap();
        client.connect(peer).expect("Could not connect to peer");
        client.send(msg.to_msg().as_str(), 0).unwrap();
        client.recv_msg(0).unwrap(); // Wait for ack...
    }
pub fn send_msg ( & self , peer : & str , msg : & Msg ) { let client = & self . ctxt . socket ( zmq :: REQ ) . unwrap ( ) ; client . connect ( peer ) . expect ( " " ) ; client . send ( msg . to_msg ( ) . as_str ( ) , 0 ) . unwrap ( ) ; client . recv_msg ( 0 ) . unwrap ( ) ; // Wait for ack... }
send a message to a particular peer.
send a message to a particular peer .
&self
peer
&str
msg
&Msg
&self
peer
&str
msg
&Msg