svn commit: r799336 - in /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network: DuplexNetworkTest.java SimpleNetworkTest.java

[gtully]

Author: gtully
Date: Thu Jul 30 15:49:08 2009
New Revision: 799336

URL: http://svn.apache.org/viewvc?rev=799336&view=rev
Log:
attempt to prevent receive blocking in the event of messages present on slower 
machines or solaris

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

Modified: 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/DuplexNetworkTest.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/DuplexNetworkTest.java?rev=799336&r1=799335&r2=799336&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/DuplexNetworkTest.java
 (original)
+++ 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/DuplexNetworkTest.java
 Thu Jul 30 15:49:08 2009
@@ -17,8 +17,6 @@
 package org.apache.activemq.network;
 
 import org.apache.activemq.broker.BrokerService;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
 
 public class DuplexNetworkTest extends SimpleNetworkTest {
 

Modified: 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java?rev=799336&r1=799335&r2=799336&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
 (original)
+++ 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
 Thu Jul 30 15:49:08 2009
@@ -170,6 +170,8 @@
         localBroker.start();
         URI localURI = localBroker.getVmConnectorURI();
         ActiveMQConnectionFactory fac = new 
ActiveMQConnectionFactory(localURI);
+        fac.setAlwaysSyncSend(true);
+        fac.setDispatchAsync(false);
         localConnection = fac.createConnection();
         localConnection.setClientID("local");
         localConnection.start();