activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r635688 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkFailoverTest.java
Date Mon, 10 Mar 2008 20:54:57 GMT
Author: rajdavies
Date: Mon Mar 10 13:54:54 2008
New Revision: 635688

URL: http://svn.apache.org/viewvc?rev=635688&view=rev
Log:
take out System println messages

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkFailoverTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkFailoverTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkFailoverTest.java?rev=635688&r1=635687&r2=635688&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkFailoverTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkFailoverTest.java
Mon Mar 10 13:54:54 2008
@@ -72,13 +72,11 @@
                 try {
                     TextMessage textMsg = (TextMessage)msg;
                     String payload = "REPLY: " + textMsg.getText();
-                    System.err.println("REMOTE CONSUMER GOT MSG "+ textMsg.getText());
                     Destination replyTo;
                     replyTo = msg.getJMSReplyTo();
                     textMsg.clearBody();
                     textMsg.setText(payload);
                     remoteProducer.send(replyTo, textMsg);  
-                    System.err.println("REMOTE CONSUMER SENT BACK MSG "+ textMsg.getText());
                     
                 } catch (Exception e) {
                     e.printStackTrace();
@@ -92,15 +90,13 @@
         MessageConsumer requestConsumer = localSession.createConsumer(tempQueue);
        
         // allow for consumer infos to perculate arround
-        System.err.println("SLEEPING ...");
         Thread.sleep(2000);
         for (int i = 0; i < MESSAGE_COUNT; i++) {
             String payload = "test msg " + i;
             TextMessage msg = localSession.createTextMessage(payload);
             msg.setJMSReplyTo(tempQueue);
-            System.err.println("SENDING REQUEST " + payload);
             requestProducer.send(msg);
-            System.err.println("FAILOVER");
+            LOG.info("Failing over");
             ((FailoverTransport) ((TransportFilter) ((TransportFilter) 
                     ((ActiveMQConnection) localConnection)
                     .getTransport()).getNext()).getNext())



Mime
View raw message