in appactive-java-client/client-channel/src/main/java/io/appactive/channel/file/FileWriteDataSource.java [57:77]
private boolean syncWriteFile(T value) throws Exception {
String convertResult = converterInterface.convert(value);
FileOutputStream outputStream = null;
try {
outputStream = new FileOutputStream(file);
byte[] bytesArray = convertResult.getBytes(charset);
LogUtil.info("[FileWritableDataSource] Writing to file {}: {}", file, convertResult);
outputStream.write(bytesArray);
outputStream.flush();
} finally {
if (outputStream != null) {
try {
outputStream.close();
} catch (Exception ignore) {
// nothing
}
}
}
return true;
}