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

set async=false for network connectors 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@553094 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-07-04 06:33:48 +00:00
parent 241971a133
commit 4757541f96
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
View File

@ -283,6 +283,7 @@ public class BrokerService implements Service {
URI uri = getVmConnectorURI(); URI uri = getVmConnectorURI();
HashMap map = new HashMap(URISupport.parseParamters(uri)); HashMap map = new HashMap(URISupport.parseParamters(uri));
map.put("network", "true"); map.put("network", "true");
map.put("async","false");
uri = URISupport.createURIWithQuery(uri, URISupport.createQueryString(map)); uri = URISupport.createURIWithQuery(uri, URISupport.createQueryString(map));
connector.setLocalUri(uri); connector.setLocalUri(uri);
@ -1605,10 +1606,15 @@ public class BrokerService implements Service {
this.transportConnectors.clear(); this.transportConnectors.clear();
setTransportConnectors(al); 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();) { for (Iterator iter = getNetworkConnectors().iterator(); iter.hasNext();) {
NetworkConnector connector = (NetworkConnector) iter.next(); NetworkConnector connector = (NetworkConnector) iter.next();
connector.setLocalUri(getVmConnectorURI()); connector.setLocalUri(uri);
connector.setBrokerName(getBrokerName()); connector.setBrokerName(getBrokerName());
connector.setDurableDestinations(getBroker().getDurableDestinations()); connector.setDurableDestinations(getBroker().getDurableDestinations());
connector.start(); connector.start();