activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r1196710 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/SoWriteTimeoutTest.java
Date Wed, 02 Nov 2011 17:23:41 GMT
Author: dejanb
Date: Wed Nov  2 17:23:39 2011
New Revision: 1196710

URL: http://svn.apache.org/viewvc?rev=1196710&view=rev
Log:
https://issues.apache.org/jira/browse/AMQ-3576 - tidying up the test

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/SoWriteTimeoutTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/SoWriteTimeoutTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/SoWriteTimeoutTest.java?rev=1196710&r1=1196709&r2=1196710&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/SoWriteTimeoutTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/SoWriteTimeoutTest.java
Wed Nov  2 17:23:39 2011
@@ -169,7 +169,6 @@ public class SoWriteTimeoutTest extends 
         ActiveMQConnectionFactory pFactory = new ActiveMQConnectionFactory("failover:(" +
proxy.getUrl() + "?soWriteTimeout=500)?jms.useAsyncSend=true&trackMessages=true");
         final Connection pc = pFactory.createConnection();
         pc.start();
-        System.out.println("Pausing proxy");
         proxy.pause();
 
         final int messageCount = 20;
@@ -178,9 +177,7 @@ public class SoWriteTimeoutTest extends 
             @Override
             public void run() {
                 try {
-                    System.out.println("sending messages");
                     sendMessages(pc, dest, messageCount);
-                    System.out.println("messages sent");
                 } catch (Exception ignored) {
                     ignored.printStackTrace();
                 }
@@ -189,7 +186,6 @@ public class SoWriteTimeoutTest extends 
 
         // wait for timeout and reconnect
         TimeUnit.SECONDS.sleep(7);
-        System.out.println("go on");
         proxy.goOn();
         for (int i=0; i<messageCount; i++) {
             assertNotNull("Got message after reconnect", consumer.receive(5000));



Mime
View raw message