} catch (IOException e) {  e.printStackTrace(); }
	public void run() throws IOException {		this.connect();				MessageBuffer messageBuffer = new MessageBuffer();				int messageLength;		short opCode;				InputStream i = connection.getInputStream();		BufferedInputStream bufferStream;		 				while ( connected ) {			/* getting length of message */			messageLength = Message.readInt32( i );			byte[] content = new byte[messageLength];			i.read(content);			messageBuffer.setBuffer(content);			opCode = messageBuffer.readInt16();			/* decode the message content */			this.decodeMessage( opCode, messageBuffer);		}	}