qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject svn commit: r602086 - in /incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample: direct/ pubsub/ requestResponse/
Date Fri, 07 Dec 2007 12:55:27 GMT
Author: arnaudsimon
Date: Fri Dec  7 04:55:26 2007
New Revision: 602086

URL: http://svn.apache.org/viewvc?rev=602086&view=rev
Log:
clean up output

Modified:
    incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Consumer.java
    incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Listener.java
    incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
    incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/MessageMirror.java
    incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/P2PRequestor.java
    incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/PubSubRequestor.java

Modified: incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Consumer.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Consumer.java?rev=602086&r1=602085&r2=602086&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Consumer.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Consumer.java
Fri Dec  7 04:55:26 2007
@@ -109,20 +109,19 @@
             boolean end = false;
             while (!end)
             {
-                System.out.println(CLASS + ": Receiving a message");
                 message = messageConsumer.receive();
                 if (message instanceof TextMessage)
                 {
-                    System.out.println(" - contents = " + ((TextMessage) message).getText());
+                    System.out.println(CLASS + ": Received  message:  " + ((TextMessage)
message).getText());
                     if (((TextMessage) message).getText().equals("That's all, folks!"))
                     {
-                        System.out.println("Received final message for " + _queueName);
+                        System.out.println(CLASS + ": Received final message for " + _queueName);
                         end = true;
                     }
                 }
                 else
                 {
-                    System.out.println(" not text message");
+                    System.out.println(CLASS + ": Received messages is  not a text message");
                 }
             }
 

Modified: incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Listener.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Listener.java?rev=602086&r1=602085&r2=602086&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Listener.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Listener.java
Fri Dec  7 04:55:26 2007
@@ -166,10 +166,10 @@
         {
             if (message instanceof TextMessage)
             {
-                System.out.println(" - contents = " + ((TextMessage) message).getText());
+                System.out.println(CLASS + ": Received message: " + ((TextMessage) message).getText());
                 if (((TextMessage) message).getText().equals("That's all, folks!"))
                 {
-                    System.out.println("Shutting down listener for " + _queueName);
+                    System.out.println(CLASS + ": Shutting down listener for " + _queueName);
                     synchronized (_lock)
                     {
                         _finished = true;

Modified: incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java?rev=602086&r1=602085&r2=602086&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/pubsub/Listener.java
Fri Dec  7 04:55:26 2007
@@ -185,13 +185,11 @@
                 // Increment the number of messages that have been received
                 _messageCount = _messageCount + 1;
                 // Print out the details of the just received message
-                System.out
-                        .print(_topicName + ":  message received: " + _messageCount + " "
+ message.getJMSMessageID());
-                System.out.println(" - contents = " + ((TextMessage) message).getText());
+                System.out.println(CLASS + ":  Received message:  " + ((TextMessage) message).getText());
                 // If this is the total number of messages required
                 if (((TextMessage) message).getText().equals("That's all, folks!"))
                 {
-                    System.out.println("Shutting down listener for " + _topicName);
+                    System.out.println(CLASS + ": Shutting down listener for " + _topicName);
                     synchronized (_lock)
                     {
                         _finished++;

Modified: incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/MessageMirror.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/MessageMirror.java?rev=602086&r1=602085&r2=602086&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/MessageMirror.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/MessageMirror.java
Fri Dec  7 04:55:26 2007
@@ -156,13 +156,13 @@
                 // Now bounce the message if a ReplyTo header was set.
                 if (requestMessage.getJMSReplyTo() != null)
                 {
-                    System.out.println("Activating response queue listener for: " + destination);
+                    System.out.println(CLASS + ": Activating response queue listener for:
" + destination);
                     responseMessage =
                             session.createTextMessage();
                      if (requestMessage instanceof TextMessage)
                     {
                        responseMessage.setText(((TextMessage) requestMessage).getText().toUpperCase());
-                        System.out.println("\tResponse = " + responseMessage.getText());
                       
+                        System.out.println(CLASS + ": \tResponse = " + responseMessage.getText());
                     }
                     messageProducer = session.createProducer(requestMessage.getJMSReplyTo());
                     messageProducer.send(responseMessage);

Modified: incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/P2PRequestor.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/P2PRequestor.java?rev=602086&r1=602085&r2=602086&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/P2PRequestor.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/P2PRequestor.java
Fri Dec  7 04:55:26 2007
@@ -146,11 +146,11 @@
     {
         Message response;
         response = requestor.request(request);
-        System.out.println("\tRequest Contents= " + request.getText());
+        System.out.println(CLASS + ": \tRequest Content= " + request.getText());
         // Print out the details of the response received
         if (response instanceof TextMessage)
         {
-            System.out.println("\t Response Contents= " + ((TextMessage) response).getText());
+            System.out.println(CLASS + ": \t Response Content= " + ((TextMessage) response).getText());
         }
     }
 }

Modified: incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/PubSubRequestor.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/PubSubRequestor.java?rev=602086&r1=602085&r2=602086&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/PubSubRequestor.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/requestResponse/PubSubRequestor.java
Fri Dec  7 04:55:26 2007
@@ -142,11 +142,11 @@
     {
         Message response;
         response = requestor.request(request);
-        System.out.println("\tRequest Contents= " + request.getText());
+        System.out.println(CLASS + ": \tRequest Content= " + request.getText());
         // Print out the details of the response received
         if (response instanceof TextMessage)
         {
-            System.out.println("\t Response Contents= " + ((TextMessage) response).getText());
+            System.out.println(CLASS + ": \t Response Content= " + ((TextMessage) response).getText());
         }
     }
 }



Mime
View raw message