ARTEMIS-4503 Use BufferedOutputStream on ./artemis consumer --data

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;
       }
    }