Untitled

public void run() {		try {			int b;			boolean msg = false;						while ((b = is.read()) != -1) {				if(((byte)b == INICIO_MENSAGEM)) {					//estou a receber uma mensagem.					msg = true;				} else {					if(msg) {						int tam = is.read()*256 + is.read();						buf = ByteBuffer.allocate(tam);						msg = false;					} else {						if((byte)b == FIM_MENSAGEM) {							//a mensagem acabou pode enviar pra tela.						} else {							buf.put((byte)b);						}					}				}			}		} catch (IOException e) {			e.printStackTrace();		}	}