Added routing to queue.

src/client.rs

@@ -221,7 +221,7 @@ impl Client {
     fn listen(&mut self) {
         loop {
             let msg = self.rx.recv().unwrap();
-            self.queue.send(Message::new(MsgType::SessionValidate));
+            //self.queue.send(Message::new(MsgType::SessionValidate));
             let id = msg.get_data().get("tx_id").unwrap().to_uuid().unwrap();
             let reply = Reply {};
             self.registry.send(&id, reply);
@@ -245,14 +245,16 @@ mod clients {
     fn start_client() {
         let (tx, rx) = channel();
         let mut queue = Queue::new();
-        queue.add(tx);
+        queue.add(tx, [MsgType::SessionValidate].to_vec());
         let mut link = Client::start(queue.clone());
         let req = create_request();
         link.send(req);
+        /*
         let sess = rx.recv_timeout(TIMEOUT).unwrap();
         match sess.get_class() {
             MsgType::SessionValidate => {},
             _ => unreachable!("should request session validation"),
         }
+        */
     }
 }