From 4578c15281176989b398e9a2690bfa24ad1ce965 Mon Sep 17 00:00:00 2001
From: Pat Fox <pat.g.fox@gmail.com>
Date: Wed, 9 Aug 2017 18:28:27 +0200
Subject: [PATCH] NO-JIRA minor update to log messages on the CLI browsing

---
 .../artemis/cli/commands/messages/ConsumerThread.java     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/ConsumerThread.java b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/ConsumerThread.java
index b69e618e2d..7883e5844d 100644
--- a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/ConsumerThread.java
+++ b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/ConsumerThread.java
@@ -69,7 +69,7 @@ public class ConsumerThread extends Thread {
       running = true;
       QueueBrowser consumer = null;
       String threadName = Thread.currentThread().getName();
-      System.out.println(threadName + " wait until " + messageCount + " messages are consumed");
+      System.out.println(threadName + " trying to browse " + messageCount + " messages");
       try {
          if (filter != null) {
             consumer = session.createBrowser((Queue) destination, filter);
@@ -81,7 +81,7 @@ public class ConsumerThread extends Thread {
          while (enumBrowse.hasMoreElements()) {
             Message msg = enumBrowse.nextElement();
             if (msg != null) {
-               System.out.println(threadName + " Received " + (msg instanceof TextMessage ? ((TextMessage) msg).getText() : msg.getJMSMessageID()));
+               System.out.println(threadName + " browsing " + (msg instanceof TextMessage ? ((TextMessage) msg).getText() : msg.getJMSMessageID()));
 
                if (verbose) {
                   System.out.println("..." + msg);
@@ -115,7 +115,7 @@ public class ConsumerThread extends Thread {
             finished.countDown();
          }
          if (consumer != null) {
-            System.out.println(threadName + " Consumed: " + this.getReceived() + " messages");
+            System.out.println(threadName + " browsed: " + this.getReceived() + " messages");
             try {
                consumer.close();
             } catch (JMSException e) {
@@ -124,7 +124,7 @@ public class ConsumerThread extends Thread {
          }
       }
 
-      System.out.println(threadName + " Consumer thread finished");
+      System.out.println(threadName + " Browser thread finished");
    }
 
    public void consume() {