docs: @Override
  	public T deserialize(byte[] message) {
  		if (dis != null) {
  			dis.setBuffer(message);
  		} else {
  			dis = new DataInputDeserializer(message);
  		}
  
  		try {
  			return serializer.deserialize(dis);
  		}
  		catch (IOException e) {
  			throw new RuntimeException("Unable to deserialize message", e);
  		}
  	}