[activemq] branch activemq-5.15.x 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 activemq-5.15.x
in repository https://gitbox.apache.org/repos/asf/activemq.git


The following commit(s) were added to refs/heads/activemq-5.15.x by this push:
     new 4fb925d  close DataByteArrayOutputStream buff of WriteBatch
4fb925d is described below

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

    close DataByteArrayOutputStream buff of WriteBatch
    
    (cherry picked from commit 0262338687d7bf811ad9ee0620f77806bd7e08ad)
---
 .../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();