activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r553094 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
Date Wed, 04 Jul 2007 06:33:48 GMT
Author: rajdavies
Date: Tue Jul  3 23:33:48 2007
New Revision: 553094

URL: http://svn.apache.org/viewvc?view=rev&rev=553094
Log:
set async=false for network connectors

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java?view=diff&rev=553094&r1=553093&r2=553094
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
Tue Jul  3 23:33:48 2007
@@ -283,6 +283,7 @@
         URI uri = getVmConnectorURI();
         HashMap map = new HashMap(URISupport.parseParamters(uri));
         map.put("network", "true");
+        map.put("async","false");
         uri = URISupport.createURIWithQuery(uri, URISupport.createQueryString(map));
         connector.setLocalUri(uri);
         
@@ -1605,10 +1606,15 @@
             	this.transportConnectors.clear();
             	setTransportConnectors(al);
             }
+            URI uri = getVmConnectorURI();
+            HashMap map = new HashMap(URISupport.parseParamters(uri));
+            map.put("network", "true");
+            map.put("async","false");
+            uri = URISupport.createURIWithQuery(uri, URISupport.createQueryString(map));
 
             for (Iterator iter = getNetworkConnectors().iterator(); iter.hasNext();) {
                 NetworkConnector connector = (NetworkConnector) iter.next();
-                connector.setLocalUri(getVmConnectorURI());
+                connector.setLocalUri(uri);
                 connector.setBrokerName(getBrokerName());
                 connector.setDurableDestinations(getBroker().getDurableDestinations());
                 connector.start();



Mime
View raw message