(activemq-artemis) branch main updated: ARTEMIS-4503 Use BufferedOutputStream on ./artemis consumer --data

[clebertsuconic]

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

clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/main by this push:
     new 6e28e46834 ARTEMIS-4503 Use BufferedOutputStream on ./artemis consumer 
--data
6e28e46834 is described below

commit 6e28e4683458490ab0e3990ba8f35e9c6531c461
Author: Clebert Suconic <clebertsuco...@apache.org>
AuthorDate: Mon Nov 13 15:37:28 2023 -0500

    ARTEMIS-4503 Use BufferedOutputStream on ./artemis consumer --data
---
 .../activemq/artemis/cli/commands/messages/Consumer.java     | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git 
a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/Consumer.java
 
b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/Consumer.java
index e137d04165..a14a820c9c 100644
--- 
a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/Consumer.java
+++ 
b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/Consumer.java
@@ -23,6 +23,7 @@ import javax.jms.Destination;
 import javax.jms.Message;
 import javax.jms.MessageListener;
 import javax.jms.Session;
+import java.io.BufferedOutputStream;
 import java.io.FileOutputStream;
 import java.io.OutputStream;
 
@@ -55,6 +56,8 @@ public class Consumer extends DestAbstract {
 
       context.out.println("Consumer:: filter = " + filter);
 
+      OutputStream outputStream = null;
+
       SerialiserMessageListener listener = null;
       MessageSerializer serializer = null;
       if (file != null) {
@@ -64,15 +67,14 @@ public class Consumer extends DestAbstract {
             return null;
          }
 
-         OutputStream out;
          try {
-            out = new FileOutputStream(file);
+            outputStream = new BufferedOutputStream(new 
FileOutputStream(file));
          } catch (Exception e) {
             System.err.println("Error: Unable to open file for writing\n" + 
e.getMessage());
             return null;
          }
 
-         listener = new SerialiserMessageListener(serializer, out);
+         listener = new SerialiserMessageListener(serializer, outputStream);
          serializer.start();
       }
 
@@ -122,6 +124,10 @@ public class Consumer extends DestAbstract {
             serializer.stop();
          }
 
+         if (outputStream != null) {
+            outputStream.close();
+         }
+
          return received;
       }
    }