servicemix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ff...@apache.org
Subject svn commit: r615110 - /servicemix/smx3/trunk/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java
Date Fri, 25 Jan 2008 05:04:30 GMT
Author: ffang
Date: Thu Jan 24 21:04:29 2008
New Revision: 615110

URL: http://svn.apache.org/viewvc?rev=615110&view=rev
Log:
[SM-1210] provide locationURI attribute for cxfbc:consumer endpoint so that customer can specify
the address which will override the one in wsdl 

Modified:
    servicemix/smx3/trunk/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java

Modified: servicemix/smx3/trunk/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/trunk/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java?rev=615110&r1=615109&r2=615110&view=diff
==============================================================================
--- servicemix/smx3/trunk/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java
(original)
+++ servicemix/smx3/trunk/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java
Thu Jan 24 21:04:29 2008
@@ -125,6 +125,8 @@
     private Bus bus;
     
     private boolean mtomEnabled;
+    
+    private String locationURI;
 
     /**
      * @return the wsdl
@@ -173,10 +175,7 @@
         outFault = interceptors;
     }
 
-    @Override
-    public String getLocationURI() {
-        return null;
-    }
+   
 
     public void process(MessageExchange exchange) throws Exception {
         Message message = messages.remove(exchange.getExchangeId());
@@ -245,6 +244,11 @@
             if (endpoint == null) {
                 endpoint = ei.getName().getLocalPart();
             }
+            
+            if (locationURI != null) {
+                ei.setAddress(locationURI);
+            }
+            
             ei.getBinding().setProperty(
                     AbstractBindingFactory.DATABINDING_DISABLED, Boolean.TRUE);
             
@@ -304,7 +308,7 @@
                     getBus().getOutInterceptors());
             cxfService.getOutFaultInterceptors().addAll(
                     getBus().getOutFaultInterceptors());
-
+            
             
             chain = new JbiChainInitiationObserver(ep, getBus());
             server = new ServerImpl(getBus(), ep, null, chain);
@@ -329,6 +333,14 @@
         }
     }
 
+    public void setLocationURI(String locationURI) {
+        this.locationURI = locationURI;
+    }
+
+    public String getLocationURI() {
+        return locationURI;
+    }
+    
     protected class JbiChainInitiationObserver extends ChainInitiationObserver {
 
         public JbiChainInitiationObserver(Endpoint endpoint, Bus bus) {



Mime
View raw message