| commit | 225fbe70439043f23e8490b51894f89ec50c8954 | [log] [tgz] |
|---|---|---|
| author | Guillaume Nodet <gnodet@apache.org> | Fri Sep 06 08:53:07 2013 +0000 |
| committer | Guillaume Nodet <gnodet@apache.org> | Fri Sep 06 08:53:07 2013 +0000 |
| tree | b6d0dc1780e83e07445bdd11a26b3f727db8ffb2 | |
| parent | cca44cb5a09c2468a0eef31078d2e9a20ba20792 [diff] |
[SMX4-1546] The cxf nmr transport should provide a synchronous option git-svn-id: https://svn.apache.org/repos/asf/servicemix/smx4/features/trunk@1520516 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRDestination.java b/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRDestination.java index 25cbe51..4919907 100644 --- a/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRDestination.java +++ b/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRDestination.java
@@ -85,7 +85,19 @@ this.properties.put(Endpoint.SERVICE_NAME, info.getService().getName().toString()); this.properties.put(Endpoint.INTERFACE_NAME, info.getInterface().getName().toString()); - + if (address.indexOf("?") > 0) { + String[] props = address.substring(address.indexOf("?") + 1).split("&"); + for (String prop : props) { + if (prop.indexOf("=") > 0) { + String key = prop.substring(0, prop.indexOf("=")); + String val = prop.substring(prop.indexOf("=") + 1); + if (key.equals("synchronous")) { + key = Endpoint.CHANNEL_SYNC_DELIVERY; + } + this.properties.put(key, val); + } + } + } } public void setChannel(Channel dc) {