[jboss-svn-commits] JBL Code SVN: r24819 - labs/jbossesb/trunk/product/services/soap/src/main/java/org/jboss/soa/esb/actions/soap/wise.

[jboss-svn-commits at lists.jboss.org]

Author: maeste
Date: 2009-01-20 03:57:55 -0500 (Tue, 20 Jan 2009)
New Revision: 24819

Modified:
   labs/jbossesb/trunk/product/services/soap/src/main/java/org/jboss/soa/esb/actions/soap/wise/SOAPClient.java
Log:
JBESB-2277: adding support for binding and catalog file; JBESB-2299:.
adding support for MTOM

Modified: labs/jbossesb/trunk/product/services/soap/src/main/java/org/jboss/soa/esb/actions/soap/wise/SOAPClient.java
===================================================================
--- labs/jbossesb/trunk/product/services/soap/src/main/java/org/jboss/soa/esb/actions/soap/wise/SOAPClient.java	2009-01-20 08:33:43 UTC (rev 24818)
+++ labs/jbossesb/trunk/product/services/soap/src/main/java/org/jboss/soa/esb/actions/soap/wise/SOAPClient.java	2009-01-20 08:57:55 UTC (rev 24819)
@@ -22,6 +22,7 @@
 
 package org.jboss.soa.esb.actions.soap.wise;
 
+import java.io.File;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -43,6 +44,7 @@
 import org.jboss.wise.core.handlers.SmooksHandler;
 import org.jboss.wise.core.mapper.SmooksMapper;
 import org.jboss.wise.core.mapper.WiseMapper;
+import org.jboss.wise.core.wsextensions.impl.MTOMEnabler;
 import org.jboss.wise.core.wsextensions.impl.WSAddressingEnabler;
 import org.jboss.wise.core.wsextensions.impl.WSSecurityEnabler;
 import org.apache.log4j.Logger;
@@ -165,13 +167,15 @@
     private String serviceName;
     private final String username;
     private final String password;
-    // private WSDynamicClient client;
+    private final String catalogFileName;
     private final List<String> smooksHandler = new ArrayList<String>();
     private final List<String> customHandlers = new ArrayList<String>();
+    private final List<String> bindingFileNames = new ArrayList<String>();
     private final MessagePayloadProxy payloadProxy;
     private boolean loggingEnabled = false;
     private boolean wsseEnabled = false;
     private boolean wsaEnabled = false;
+    private boolean mtomEnabled = false;
     private String smooksRequestReport = null;
     private String smooksResponseReport = null;
 
@@ -197,6 +201,8 @@
         logger.info("wsseEnabled:" + wsseEnabled);
         wsaEnabled = Boolean.parseBoolean(config.getAttribute("enableWSA"));
         logger.info("wsaEnabled:" + wsaEnabled);
+        mtomEnabled = Boolean.parseBoolean(config.getAttribute("enableMTOM"));
+        logger.info("mtomEnabled:" + mtomEnabled);
 
         ConfigTree[] handlersConfig;
         if (config.getAttribute("smooks-handler-config") != null) {
@@ -208,6 +214,15 @@
             }
 
         }
+        if (config.getAttribute("binding-files") != null) {
+            for (String fileName : config.getAttribute("binding-files").split(";")) {
+                bindingFileNames.add(fileName);
+            }
+
+        }
+
+        catalogFileName = config.getAttribute("catalog-file");
+
         handlersConfig = config.getChildren("custom-handlers");
 
         payloadProxy = new MessagePayloadProxy(config);
@@ -224,7 +239,14 @@
         logger.info("DEPLOY #1");
         // get client from cache
         try {
-            client = WSDynamicClientFactory.getInstance().getJAXWSClient(wsdl, username, password);
+            List<File> bindings = new java.util.ArrayList<File>();
+
+            for (String fileName : bindingFileNames) {
+                File bindFile = new File(fileName);
+                bindings.add(bindFile);
+            }
+            File catalog = new File(catalogFileName);
+            client = WSDynamicClientFactory.getInstance().getJAXWSClient(wsdl, username, password, null, bindings, catalog);
         } catch (Exception e) {
             e.printStackTrace();
             throw new ActionProcessingException("Error durinfg wise client creation", e);
@@ -257,13 +279,14 @@
                 logger.info("enabling wsa");
                 this.getEndpoint().addWSExtension(new WSAddressingEnabler());
             }
+            if (mtomEnabled) {
+                logger.info("enabling mtom");
+                this.getEndpoint().addWSExtension(new MTOMEnabler());
+            }
         } catch (Exception e) {
             e.printStackTrace();
         }
 
-        // this.getEndpoint().setUsername(username);
-        // this.getEndpoint().setPassword(password);
-
     }
 
     @Override