@Override
	public void run() {
		
		listener.start();
		
		print("I'm alive");
		Message msg;
		
		while(true){
			//test();
			
			msg = msgQueue.poll();
			while(msg == null){
				try {
					Thread.sleep(2000);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				msg = msgQueue.poll();
			}
			if(connectedServ == null){
				print("not connected to a server");
				continue;
			}
			msgSwitch(msg);
			
		}
		
		//AddMessage amsg = new AddMessage(procid, "Dan", "is dumb");
		//sendMsg(connectedServ, amsg);
		//ReadMessage rmsg = new ReadMessage(procid, "Dan");
		
	}