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