activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r799336 - in /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network: DuplexNetworkTest.java SimpleNetworkTest.java
Date Thu, 30 Jul 2009 15:49:08 GMT
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();



Mime
View raw message