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();