inputStream = new ByteArrayInputStream(body.getBytes("UTF-8"));
} else {
inputStream = replicationPackage.createInputStream();
}
req = req.bodyStream(inputStream, ContentType.APPLICATION_OCTET_STREAM);
response = executor.execute(req);
} finally {
IOUtils.closeQuietly(inputStream);
}