code: private void _decompressMessageData(Message msg) {
  		if((msg.flags & Message.FLAGS_COMPRESSED) == 0) {
  			throw new IllegalArgumentException("message data is not compressed");
  		}
  		Inflater decompresser = new Inflater();
  		decompresser.setInput(msg.data);
  		ByteArrayOutputStream bos = new ByteArrayOutputStream(msg.data.length);
  		byte[] buffer = new byte[8192];
  		try {
  			while (!decompresser.finished()) {
  				int size = decompresser.inflate(buffer);
  				bos.write(buffer, 0, size);
  			}
  			msg.data = bos.toByteArray();
  			msg.flags &= ~Message.FLAGS_COMPRESSED;
  			decompresser.end();
  		} catch (DataFormatException e) {
  			throw new PyroException("invalid compressed data: ", e);
  		}
  	}
docs: Decompress the data bytes in the given message (in place).