You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2009/07/30 17:49:08 UTC
svn commit: r799336 - in
/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network:
DuplexNetworkTest.java SimpleNetworkTest.java
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();