Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

take out System println messages 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@635688 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-03-10 20:54:54 +00:00
parent 044c07d9a5
commit 29cfdedb12
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/test/java/org/apache/activemq/network/NetworkFailoverTest.java
View File

@ -72,13 +72,11 @@ public class NetworkFailoverTest extends TestCase {
try { try {
TextMessage textMsg = (TextMessage)msg; TextMessage textMsg = (TextMessage)msg;
String payload = "REPLY: " + textMsg.getText(); String payload = "REPLY: " + textMsg.getText();
System.err.println("REMOTE CONSUMER GOT MSG "+ textMsg.getText());
Destination replyTo; Destination replyTo;
replyTo = msg.getJMSReplyTo(); replyTo = msg.getJMSReplyTo();
textMsg.clearBody(); textMsg.clearBody();
textMsg.setText(payload); textMsg.setText(payload);
remoteProducer.send(replyTo, textMsg); remoteProducer.send(replyTo, textMsg);
System.err.println("REMOTE CONSUMER SENT BACK MSG "+ textMsg.getText());
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
@ -92,15 +90,13 @@ public class NetworkFailoverTest extends TestCase {
MessageConsumer requestConsumer = localSession.createConsumer(tempQueue); MessageConsumer requestConsumer = localSession.createConsumer(tempQueue);
// allow for consumer infos to perculate arround // allow for consumer infos to perculate arround
System.err.println("SLEEPING ...");
Thread.sleep(2000); Thread.sleep(2000);
for (int i = 0; i < MESSAGE_COUNT; i++) { for (int i = 0; i < MESSAGE_COUNT; i++) {
String payload = "test msg " + i; String payload = "test msg " + i;
TextMessage msg = localSession.createTextMessage(payload); TextMessage msg = localSession.createTextMessage(payload);
msg.setJMSReplyTo(tempQueue); msg.setJMSReplyTo(tempQueue);
System.err.println("SENDING REQUEST " + payload);
requestProducer.send(msg); requestProducer.send(msg);
System.err.println("FAILOVER"); LOG.info("Failing over");
((FailoverTransport) ((TransportFilter) ((TransportFilter) ((FailoverTransport) ((TransportFilter) ((TransportFilter)
((ActiveMQConnection) localConnection) ((ActiveMQConnection) localConnection)
.getTransport()).getNext()).getNext()) .getTransport()).getNext()).getNext())