[activemq] branch master updated: close DataByteArrayOutputStream buff of WriteBatch

[jbonofre]

This is an automated email from the ASF dual-hosted git repository.

jbonofre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq.git


The following commit(s) were added to refs/heads/master by this push:
     new 0262338  close DataByteArrayOutputStream buff of WriteBatch
     new a053194  Merge pull request #348 from nguyenhoan/patch-1
0262338 is described below

commit 0262338687d7bf811ad9ee0620f77806bd7e08ad
Author: Hoan Nguyen <nguyenanhh...@gmail.com>
AuthorDate: Tue Feb 26 19:07:26 2019 -0800

    close DataByteArrayOutputStream buff of WriteBatch
---
 .../store/kahadb/disk/journal/CallerBufferingDataFileAppender.java     | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/CallerBufferingDataFileAppender.java
 
b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/CallerBufferingDataFileAppender.java
index d6a9d2e..2f495a1 100644
--- 
a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/CallerBufferingDataFileAppender.java
+++ 
b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/CallerBufferingDataFileAppender.java
@@ -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();