You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2013/09/06 10:53:08 UTC
svn commit: r1520516 -
/servicemix/smx4/features/trunk/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRDestination.java
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) {