activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/2] activemq-artemis git commit: NO-JIRA minor update to log messages on the CLI browsing
Date Tue, 15 Aug 2017 17:06:47 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master cb7183c47 -> f2f4708eb


NO-JIRA minor update to log messages on the CLI browsing


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/4578c152
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/4578c152
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/4578c152

Branch: refs/heads/master
Commit: 4578c15281176989b398e9a2690bfa24ad1ce965
Parents: cb7183c
Author: Pat Fox <pat.g.fox@gmail.com>
Authored: Wed Aug 9 18:28:27 2017 +0200
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Tue Aug 15 13:05:42 2017 -0400

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


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/4578c152/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/ConsumerThread.java
----------------------------------------------------------------------
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 b69e618..7883e58 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() {


Mime
View raw message