servicemix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gno...@apache.org
Subject svn commit: r1520516 - /servicemix/smx4/features/trunk/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRDestination.java
Date Fri, 06 Sep 2013 08:53:08 GMT
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) {



Mime
View raw message