Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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
This commit is contained in:
Gary Tully 2009-07-30 15:49:08 +00:00
parent fc63a92339
commit dbefbecf1a
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-core/src/test/java/org/apache/activemq/network/DuplexNetworkTest.java
View File

@ -17,8 +17,6 @@
package org.apache.activemq.network; package org.apache.activemq.network;
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.BrokerService;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
public class DuplexNetworkTest extends SimpleNetworkTest { public class DuplexNetworkTest extends SimpleNetworkTest {

2
activemq-core/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
View File

@ -170,6 +170,8 @@ public class SimpleNetworkTest extends TestCase {
localBroker.start(); localBroker.start();
URI localURI = localBroker.getVmConnectorURI(); URI localURI = localBroker.getVmConnectorURI();
ActiveMQConnectionFactory fac = new ActiveMQConnectionFactory(localURI); ActiveMQConnectionFactory fac = new ActiveMQConnectionFactory(localURI);
fac.setAlwaysSyncSend(true);
fac.setDispatchAsync(false);
localConnection = fac.createConnection(); localConnection = fac.createConnection();
localConnection.setClientID("local"); localConnection.setClientID("local");
localConnection.start(); localConnection.start();