Author: gnodet
Date: Fri Sep 6 08:53:07 2013
New Revision: 1520516
URL: http://svn.apache.org/r1520516
Log:
[SMX4-1546] The cxf nmr transport should provide a synchronous option
Modified:
servicemix/smx4/features/trunk/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRDestination.java
Modified:
servicemix/smx4/features/trunk/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRDestination.java
URL:
http://svn.apache.org/viewvc/servicemix/smx4/features/trunk/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRDestination.java?rev=1520516&r1=1520515&r2=1520516&view=diff
==============================================================================
---
servicemix/smx4/features/trunk/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRDestination.java
(original)
+++
servicemix/smx4/features/trunk/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRDestination.java
Fri Sep 6 08:53:07 2013
@@ -85,7 +85,19 @@ public class NMRDestination extends Abst
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) {
