@Override
	public void run(){
		int ID = cluster.getID() + 0;
		try{
			String msg = "";
			setThreadName("Msg4"+cluster.getID());
			while(alive){
				try{
					while((msg = getClient().getReader().readLine())!= null){
						//getParser().parse(msg);
						try{
							Bukkit.getServer().getPluginManager().callEvent(new MessageEvent(msg,cluster));
						}catch(Exception e){e.printStackTrace();}
					}
				}catch(Exception e){if(cluster!= null){cluster.Terminate();}ClientHandler.getClientMap().Debug(ID+") Ending Messager");break;}
			}
		}catch(Exception e){e.printStackTrace();}
		ClientHandler.getClientMap().Debug(ID+") "+ThreadName+"Stopped!");

	}