mirror of https://github.com/apache/activemq.git
Merge pull request #348 from nguyenhoan/patch-1
close DataByteArrayOutputStream buff of WriteBatch
This commit is contained in:
commit
a0531943a4
|
@ -195,6 +195,9 @@ class CallerBufferingDataFileAppender extends DataFileAppender {
|
|||
}
|
||||
dataFile.closeRandomAccessFile(file);
|
||||
}
|
||||
if (wb != null && wb.buff != null) {
|
||||
wb.buff.close();
|
||||
}
|
||||
} catch (Throwable ignore) {
|
||||
}
|
||||
shutdownDone.countDown();
|
||||
|
|
Loading…
Reference in New Issue