From dbefbecf1a12b8233a4e39bc3f0d2cab131ef437 Mon Sep 17 00:00:00 2001 From: Gary Tully Date: Thu, 30 Jul 2009 15:49:08 +0000 Subject: [PATCH] attempt to prevent receive blocking in the event of messages present on slower machines or solaris git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@799336 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/activemq/network/DuplexNetworkTest.java | 2 -- .../java/org/apache/activemq/network/SimpleNetworkTest.java | 2 ++ 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/activemq-core/src/test/java/org/apache/activemq/network/DuplexNetworkTest.java b/activemq-core/src/test/java/org/apache/activemq/network/DuplexNetworkTest.java index 23cbc2ca9c..f4deeb46e9 100755 --- a/activemq-core/src/test/java/org/apache/activemq/network/DuplexNetworkTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/network/DuplexNetworkTest.java @@ -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 { diff --git a/activemq-core/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java b/activemq-core/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java index 36b152f5aa..2d9882758e 100755 --- a/activemq-core/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java @@ -170,6 +170,8 @@ public class SimpleNetworkTest extends TestCase { 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();