Author: richard.opalka(a)jboss.com Date: 2010-10-15 08:46:51 -0400 (Fri, 15 Oct 2010) New Revision: 13137 Added: stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/NativeServiceObjectFactoryJAXWS.java stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/NativeServiceReferenceableJAXWS.java Removed: stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/ServiceObjectFactoryJAXWS.java stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/ServiceReferenceable.java Modified: stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/NativeServiceRefBinderJAXWS.java stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/spi/ServiceDelegateImpl.java stack/native/trunk/modules/core/src/main/java/org/jboss/ws/metadata/builder/jaxws/JAXWSClientMetaDataBuilder.java Log: refactoring Added: stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/NativeServiceObjectFactoryJAXWS.java =================================================================== --- stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/NativeServiceObjectFactoryJAXWS.java (rev 0) +++ stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/NativeServiceObjectFactoryJAXWS.java 2010-10-15 12:46:51 UTC (rev 13137) @@ -0,0 +1,454 @@ +/* + * JBoss, Home of Professional Open Source. + * Copyright 2006, Red Hat Middleware LLC, and individual contributors + * as indicated by the @author tags. See the copyright.txt file in the + * distribution for a full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.core.jaxws.client; + +import java.io.ByteArrayInputStream; +import java.io.IOException; +import java.io.ObjectInputStream; +import java.lang.reflect.Constructor; +import java.lang.reflect.InvocationTargetException; +import java.lang.reflect.Method; +import java.net.URL; +import java.util.Collection; +import java.util.Hashtable; +import java.util.LinkedList; +import java.util.List; + +import javax.naming.Context; +import javax.naming.Name; +import javax.naming.NamingException; +import javax.naming.RefAddr; +import javax.naming.Reference; +import javax.xml.namespace.QName; +import javax.xml.ws.RespectBindingFeature; +import javax.xml.ws.Service; +import javax.xml.ws.WebServiceFeature; +import javax.xml.ws.soap.AddressingFeature; +import javax.xml.ws.soap.MTOMFeature; + +import org.jboss.logging.Logger; +import org.jboss.ws.core.ConfigProvider; +import org.jboss.ws.core.client.ServiceObjectFactory; +import org.jboss.wsf.spi.WSFException; +import org.jboss.wsf.spi.metadata.j2ee.serviceref.UnifiedPortComponentRefMetaData; +import org.jboss.wsf.spi.metadata.j2ee.serviceref.UnifiedServiceRefMetaData; + +/** + * This ServiceObjectFactory reconstructs a javax.xml.ws.Service + * for a given WSDL when the webservice client does a JNDI lookup. + * + * @author Thomas.Diesler(a)jboss.org + * @author Richard.Opalka(a)jboss.org + * @since 24-Oct-2004 + */ +public class NativeServiceObjectFactoryJAXWS extends ServiceObjectFactory +{ + // provide logging + private static final Logger log = Logger.getLogger(NativeServiceObjectFactoryJAXWS.class); + + // The ServiceRefMetaData association + private static ThreadLocal<UnifiedServiceRefMetaData> serviceRefAssociation = new ThreadLocal<UnifiedServiceRefMetaData>(); + + /** + * Creates an object using the location or reference information specified. + * <p/> + * + * @param obj The possibly null object containing location or reference + * information that can be used in creating an object. + * @param name The name of this object relative to <code>nameCtx</code>, + * or null if no name is specified. + * @param nameCtx The context relative to which the <code>name</code> + * parameter is specified, or null if <code>name</code> is + * relative to the default initial context. + * @param environment The possibly null environment that is used in + * creating the object. + * @return The object created; null if an object cannot be created. + * @throws Exception if this object factory encountered an exception + * while attempting to create an object, and no other object factories are + * to be tried. + * @see javax.naming.spi.NamingManager#getObjectInstance + * @see javax.naming.spi.NamingManager#getURLContext + */ + @SuppressWarnings(value = "unchecked") + public Object getObjectInstance(final Object obj, final Name name, final Context nameCtx, final Hashtable environment) + throws Exception + { + try + { + // references + final Reference ref = (Reference) obj; + final UnifiedServiceRefMetaData serviceRef = unmarshallServiceRef(ref); + // class names + final String serviceImplClass = this.getServiceClassName(ref, serviceRef); + final String targetClassName = this.getTargetClassName(ref, serviceRef, serviceImplClass); + // class instances + final Class<?> serviceClass = this.getClass(serviceImplClass); + final Class<?> targetClass = this.getClass(targetClassName); + final Service serviceInstance; + try + { + // Associate the ServiceRefMetaData with this thread + serviceRefAssociation.set(serviceRef); + // construct service + serviceInstance = this.instantiateService(serviceRef, serviceClass); + } + finally + { + serviceRefAssociation.set(null); + } + // Configure the service + configureService(serviceInstance, serviceRef); + // construct port + final boolean instantiatePort = targetClassName != null && !targetClassName.equals(serviceImplClass); + if (instantiatePort) + { + final QName portQName = this.getPortQName(targetClassName, serviceImplClass, serviceRef); + final WebServiceFeature[] portFeatures = this.getFeatures(targetClassName, serviceImplClass, serviceRef); + + return instantiatePort(serviceClass, targetClass, serviceInstance, portQName, portFeatures); + } + + return serviceInstance; + } + catch (Exception ex) + { + WSFException.rethrow("Cannot create service", ex); + } + + return null; + } + + public static UnifiedServiceRefMetaData getServiceRefAssociation() + { + return serviceRefAssociation.get(); + } + + private void configureService(final Service service, final UnifiedServiceRefMetaData serviceRef) + { + final String configFile = serviceRef.getConfigFile(); + final String configName = serviceRef.getConfigName(); + if (service instanceof ConfigProvider) + { + if(log.isDebugEnabled()) log.debug("Configure Service: [configName=" + configName + ",configFile=" + configFile + "]"); + + final ConfigProvider cp = (ConfigProvider)service; + if (configName != null || configFile != null) + { + cp.setConfigName(configName, configFile); + } + } + } + + private Class<?> getClass(final String className) throws ClassNotFoundException + { + if (className != null) + { + return SecurityActions.getContextClassLoader().loadClass(className); + } + + return null; + } + + private String getServiceClassName(final Reference ref, final UnifiedServiceRefMetaData serviceRefMD) + { + String serviceClassName = serviceRefMD.getServiceImplClass(); + if (serviceClassName == null) + serviceClassName = (String) ref.get(NativeServiceReferenceableJAXWS.SERVICE_IMPL_CLASS).getContent(); + + return serviceClassName; + } + + private String getTargetClassName(final Reference ref, final UnifiedServiceRefMetaData serviceRefMD, + final String serviceImplClass) + { + String targetClassName = serviceRefMD.getServiceRefType(); + if (targetClassName == null) + targetClassName = (String) ref.get(NativeServiceReferenceableJAXWS.TARGET_CLASS_NAME).getContent(); + + if (Service.class.getName().equals(targetClassName)) + targetClassName = serviceImplClass; + + return targetClassName; + } + + private Object instantiatePort(final Class<?> serviceClass, final Class<?> targetClass, final Service target, + final QName portQName, final WebServiceFeature[] features) throws NoSuchMethodException, + InstantiationException, IllegalAccessException, InvocationTargetException + { + Object retVal = null; + + Object port = null; + if (serviceClass != Service.class) + { + for (Method method : serviceClass.getDeclaredMethods()) + { + String methodName = method.getName(); + Class<?> retType = method.getReturnType(); + if (methodName.startsWith("get") && targetClass.isAssignableFrom(retType)) + { + port = method.invoke(target, new Object[0]); + retVal = port; + break; + } + } + } + + if (port == null) + { + Method method = getMethodFor(portQName, features, serviceClass); + Object[] args = getArgumentsFor(portQName, features, targetClass); + port = method.invoke(target, args); + retVal = port; + } + + return retVal; + } + + private Service instantiateService(final UnifiedServiceRefMetaData serviceRefMD, final Class<?> serviceClass) + throws NoSuchMethodException, InstantiationException, IllegalAccessException, InvocationTargetException + { + final WebServiceFeature[] features = getFeatures(serviceRefMD); + final URL wsdlURL = serviceRefMD.getWsdlLocation(); + final QName serviceQName = serviceRefMD.getServiceQName(); + + Service target = null; + if (serviceClass == Service.class) + { + // Generic javax.xml.ws.Service + if (wsdlURL != null) + { + if (features != null) + { + target = Service.create(wsdlURL, serviceQName, features); + } + else + { + target = Service.create(wsdlURL, serviceQName); + } + } + else + { + throw new IllegalArgumentException("Cannot create generic javax.xml.ws.Service without wsdlLocation: " + + serviceRefMD); + } + } + else + { + // Generated javax.xml.ws.Service subclass + if (wsdlURL != null) + { + if (features != null) + { + Constructor<?> ctor = serviceClass.getConstructor(new Class[] + {URL.class, QName.class, WebServiceFeature[].class}); + target = (Service) ctor.newInstance(new Object[] + {wsdlURL, serviceQName, features}); + } + else + { + Constructor<?> ctor = serviceClass.getConstructor(new Class[] + {URL.class, QName.class}); + target = (Service) ctor.newInstance(new Object[] + {wsdlURL, serviceQName}); + } + } + else + { + if (features != null) + { + Constructor<?> ctor = serviceClass.getConstructor(new Class[] + {WebServiceFeature[].class}); + target = (Service) ctor.newInstance(new Object[] + {features}); + } + else + { + target = (Service) serviceClass.newInstance(); + } + } + } + + return target; + } + + private WebServiceFeature[] getFeatures(final String targetClassName, final String serviceClassName, + final UnifiedServiceRefMetaData serviceRefMD) + { + if (targetClassName != null && !targetClassName.equals(serviceClassName)) + { + final Collection<UnifiedPortComponentRefMetaData> portComponentRefs = serviceRefMD.getPortComponentRefs(); + for (final UnifiedPortComponentRefMetaData portComponentRefMD : portComponentRefs) + { + if (targetClassName.equals(portComponentRefMD.getServiceEndpointInterface())) + { + return getFeatures(portComponentRefMD); + } + } + } + + return null; + } + + private QName getPortQName(final String targetClassName, final String serviceClassName, + final UnifiedServiceRefMetaData serviceRefMD) + { + if (targetClassName != null && !targetClassName.equals(serviceClassName)) + { + final Collection<UnifiedPortComponentRefMetaData> portComponentRefs = serviceRefMD.getPortComponentRefs(); + for (final UnifiedPortComponentRefMetaData portComponentRefMD : portComponentRefs) + { + if (targetClassName.equals(portComponentRefMD.getServiceEndpointInterface())) + { + return portComponentRefMD.getPortQName(); + } + } + } + + return null; + } + + private Method getMethodFor(final QName portQName, final WebServiceFeature[] features, final Class<?> serviceClass) + throws NoSuchMethodException + { + if ((portQName == null) && (features == null)) + return serviceClass.getMethod("getPort", new Class[] + {Class.class}); + if ((portQName != null) && (features == null)) + return serviceClass.getMethod("getPort", new Class[] + {QName.class, Class.class}); + if ((portQName == null) && (features != null)) + return serviceClass.getMethod("getPort", new Class[] + {Class.class, WebServiceFeature[].class}); + if ((portQName != null) && (features != null)) + return serviceClass.getMethod("getPort", new Class[] + {QName.class, Class.class, WebServiceFeature[].class}); + + throw new IllegalStateException(); + } + + private Object[] getArgumentsFor(final QName portQName, final WebServiceFeature[] features, + final Class<?> targetClass) throws NoSuchMethodException + { + if ((portQName == null) && (features == null)) + return new Object[] + {targetClass}; + if ((portQName != null) && (features == null)) + return new Object[] + {portQName, targetClass}; + if ((portQName == null) && (features != null)) + return new Object[] + {targetClass, features}; + if ((portQName != null) && (features != null)) + return new Object[] + {portQName, targetClass, features}; + + throw new IllegalStateException(); + } + + private WebServiceFeature[] getFeatures(final UnifiedServiceRefMetaData serviceRef) + { + List<WebServiceFeature> features = new LinkedList<WebServiceFeature>(); + + // configure @Addressing feature + if (serviceRef.isAddressingEnabled()) + { + final boolean required = serviceRef.isAddressingRequired(); + final String refResponses = serviceRef.getAddressingResponses(); + AddressingFeature.Responses responses = AddressingFeature.Responses.ALL; + if ("ANONYMOUS".equals(refResponses)) + responses = AddressingFeature.Responses.ANONYMOUS; + if ("NON_ANONYMOUS".equals(refResponses)) + responses = AddressingFeature.Responses.NON_ANONYMOUS; + + features.add(new AddressingFeature(true, required, responses)); + } + + // configure @MTOM feature + if (serviceRef.isMtomEnabled()) + { + features.add(new MTOMFeature(true, serviceRef.getMtomThreshold())); + } + + // configure @RespectBinding feature + if (serviceRef.isRespectBindingEnabled()) + { + features.add(new RespectBindingFeature(true)); + } + + WebServiceFeature[] wsFeatures = features.size() == 0 ? null : features.toArray(new WebServiceFeature[] + {}); + return wsFeatures; + } + + private WebServiceFeature[] getFeatures(final UnifiedPortComponentRefMetaData portComponentRefMD) + { + List<WebServiceFeature> features = new LinkedList<WebServiceFeature>(); + // configure @Addressing feature + if (portComponentRefMD.isAddressingEnabled()) + { + final boolean required = portComponentRefMD.isAddressingRequired(); + final String refResponses = portComponentRefMD.getAddressingResponses(); + AddressingFeature.Responses responses = AddressingFeature.Responses.ALL; + if ("ANONYMOUS".equals(refResponses)) + responses = AddressingFeature.Responses.ANONYMOUS; + if ("NON_ANONYMOUS".equals(refResponses)) + responses = AddressingFeature.Responses.NON_ANONYMOUS; + + features.add(new AddressingFeature(true, required, responses)); + } + + // configure @MTOM feature + if (portComponentRefMD.isMtomEnabled()) + { + features.add(new MTOMFeature(true, portComponentRefMD.getMtomThreshold())); + } + + // configure @RespectBinding feature + if (portComponentRefMD.isRespectBindingEnabled()) + { + features.add(new RespectBindingFeature(true)); + } + + return features.size() == 0 ? null : features.toArray(new WebServiceFeature[] + {}); + } + + private UnifiedServiceRefMetaData unmarshallServiceRef(final Reference ref) throws ClassNotFoundException, + NamingException + { + final UnifiedServiceRefMetaData sref; + final RefAddr refAddr = ref.get(NativeServiceReferenceableJAXWS.SERVICE_REF_META_DATA); + final ByteArrayInputStream bais = new ByteArrayInputStream((byte[]) refAddr.getContent()); + try + { + ObjectInputStream ois = new ObjectInputStream(bais); + sref = (UnifiedServiceRefMetaData) ois.readObject(); + ois.close(); + } + catch (IOException e) + { + throw new NamingException("Cannot unmarshall service ref meta data, cause: " + e.toString()); + } + + return sref; + } +} Modified: stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/NativeServiceRefBinderJAXWS.java =================================================================== --- stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/NativeServiceRefBinderJAXWS.java 2010-10-15 12:43:36 UTC (rev 13136) +++ stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/NativeServiceRefBinderJAXWS.java 2010-10-15 12:46:51 UTC (rev 13137) @@ -38,6 +38,6 @@ protected Referenceable createReferenceable(final String serviceImplClass, final String targetClassName, final UnifiedServiceRefMetaData serviceRefUMDM) { - return new ServiceReferenceable(serviceImplClass, targetClassName, serviceRefUMDM); + return new NativeServiceReferenceableJAXWS(serviceImplClass, targetClassName, serviceRefUMDM); } } Added: stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/NativeServiceReferenceableJAXWS.java =================================================================== --- stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/NativeServiceReferenceableJAXWS.java (rev 0) +++ stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/NativeServiceReferenceableJAXWS.java 2010-10-15 12:46:51 UTC (rev 13137) @@ -0,0 +1,46 @@ +/* + * JBoss, Home of Professional Open Source. + * Copyright 2006, Red Hat Middleware LLC, and individual contributors + * as indicated by the @author tags. See the copyright.txt file in the + * distribution for a full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.core.jaxws.client; + +import org.jboss.wsf.common.serviceref.AbstractServiceReferenceableJAXWS; +import org.jboss.wsf.spi.metadata.j2ee.serviceref.UnifiedServiceRefMetaData; + +/** + * {@inheritDoc} + * + * @author Thomas.Diesler(a)jboss.org + * @author <a href="mailto:ropalka@redhat.com">Richard Opalka</a> + */ +public class NativeServiceReferenceableJAXWS extends AbstractServiceReferenceableJAXWS<NativeServiceObjectFactoryJAXWS> +{ + public NativeServiceReferenceableJAXWS(final String serviceImplClass, final String targetClassName, + final UnifiedServiceRefMetaData serviceRefUMDM) + { + super(serviceImplClass, targetClassName, serviceRefUMDM); + } + + @Override + protected Class<NativeServiceObjectFactoryJAXWS> getObjectFactory() + { + return NativeServiceObjectFactoryJAXWS.class; + } +} Deleted: stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/ServiceObjectFactoryJAXWS.java =================================================================== --- stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/ServiceObjectFactoryJAXWS.java 2010-10-15 12:43:36 UTC (rev 13136) +++ stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/ServiceObjectFactoryJAXWS.java 2010-10-15 12:46:51 UTC (rev 13137) @@ -1,454 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * Copyright 2006, Red Hat Middleware LLC, and individual contributors - * as indicated by the @author tags. See the copyright.txt file in the - * distribution for a full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jboss.ws.core.jaxws.client; - -import java.io.ByteArrayInputStream; -import java.io.IOException; -import java.io.ObjectInputStream; -import java.lang.reflect.Constructor; -import java.lang.reflect.InvocationTargetException; -import java.lang.reflect.Method; -import java.net.URL; -import java.util.Collection; -import java.util.Hashtable; -import java.util.LinkedList; -import java.util.List; - -import javax.naming.Context; -import javax.naming.Name; -import javax.naming.NamingException; -import javax.naming.RefAddr; -import javax.naming.Reference; -import javax.xml.namespace.QName; -import javax.xml.ws.RespectBindingFeature; -import javax.xml.ws.Service; -import javax.xml.ws.WebServiceFeature; -import javax.xml.ws.soap.AddressingFeature; -import javax.xml.ws.soap.MTOMFeature; - -import org.jboss.logging.Logger; -import org.jboss.ws.core.ConfigProvider; -import org.jboss.ws.core.client.ServiceObjectFactory; -import org.jboss.wsf.spi.WSFException; -import org.jboss.wsf.spi.metadata.j2ee.serviceref.UnifiedPortComponentRefMetaData; -import org.jboss.wsf.spi.metadata.j2ee.serviceref.UnifiedServiceRefMetaData; - -/** - * This ServiceObjectFactory reconstructs a javax.xml.ws.Service - * for a given WSDL when the webservice client does a JNDI lookup. - * - * @author Thomas.Diesler(a)jboss.org - * @author Richard.Opalka(a)jboss.org - * @since 24-Oct-2004 - */ -public class ServiceObjectFactoryJAXWS extends ServiceObjectFactory -{ - // provide logging - private static final Logger log = Logger.getLogger(ServiceObjectFactoryJAXWS.class); - - // The ServiceRefMetaData association - private static ThreadLocal<UnifiedServiceRefMetaData> serviceRefAssociation = new ThreadLocal<UnifiedServiceRefMetaData>(); - - /** - * Creates an object using the location or reference information specified. - * <p/> - * - * @param obj The possibly null object containing location or reference - * information that can be used in creating an object. - * @param name The name of this object relative to <code>nameCtx</code>, - * or null if no name is specified. - * @param nameCtx The context relative to which the <code>name</code> - * parameter is specified, or null if <code>name</code> is - * relative to the default initial context. - * @param environment The possibly null environment that is used in - * creating the object. - * @return The object created; null if an object cannot be created. - * @throws Exception if this object factory encountered an exception - * while attempting to create an object, and no other object factories are - * to be tried. - * @see javax.naming.spi.NamingManager#getObjectInstance - * @see javax.naming.spi.NamingManager#getURLContext - */ - @SuppressWarnings(value = "unchecked") - public Object getObjectInstance(final Object obj, final Name name, final Context nameCtx, final Hashtable environment) - throws Exception - { - try - { - // references - final Reference ref = (Reference) obj; - final UnifiedServiceRefMetaData serviceRef = unmarshallServiceRef(ref); - // class names - final String serviceImplClass = this.getServiceClassName(ref, serviceRef); - final String targetClassName = this.getTargetClassName(ref, serviceRef, serviceImplClass); - // class instances - final Class<?> serviceClass = this.getClass(serviceImplClass); - final Class<?> targetClass = this.getClass(targetClassName); - final Service serviceInstance; - try - { - // Associate the ServiceRefMetaData with this thread - serviceRefAssociation.set(serviceRef); - // construct service - serviceInstance = this.instantiateService(serviceRef, serviceClass); - } - finally - { - serviceRefAssociation.set(null); - } - // Configure the service - configureService(serviceInstance, serviceRef); - // construct port - final boolean instantiatePort = targetClassName != null && !targetClassName.equals(serviceImplClass); - if (instantiatePort) - { - final QName portQName = this.getPortQName(targetClassName, serviceImplClass, serviceRef); - final WebServiceFeature[] portFeatures = this.getFeatures(targetClassName, serviceImplClass, serviceRef); - - return instantiatePort(serviceClass, targetClass, serviceInstance, portQName, portFeatures); - } - - return serviceInstance; - } - catch (Exception ex) - { - WSFException.rethrow("Cannot create service", ex); - } - - return null; - } - - public static UnifiedServiceRefMetaData getServiceRefAssociation() - { - return serviceRefAssociation.get(); - } - - private void configureService(final Service service, final UnifiedServiceRefMetaData serviceRef) - { - final String configFile = serviceRef.getConfigFile(); - final String configName = serviceRef.getConfigName(); - if (service instanceof ConfigProvider) - { - if(log.isDebugEnabled()) log.debug("Configure Service: [configName=" + configName + ",configFile=" + configFile + "]"); - - final ConfigProvider cp = (ConfigProvider)service; - if (configName != null || configFile != null) - { - cp.setConfigName(configName, configFile); - } - } - } - - private Class<?> getClass(final String className) throws ClassNotFoundException - { - if (className != null) - { - return SecurityActions.getContextClassLoader().loadClass(className); - } - - return null; - } - - private String getServiceClassName(final Reference ref, final UnifiedServiceRefMetaData serviceRefMD) - { - String serviceClassName = serviceRefMD.getServiceImplClass(); - if (serviceClassName == null) - serviceClassName = (String) ref.get(ServiceReferenceable.SERVICE_IMPL_CLASS).getContent(); - - return serviceClassName; - } - - private String getTargetClassName(final Reference ref, final UnifiedServiceRefMetaData serviceRefMD, - final String serviceImplClass) - { - String targetClassName = serviceRefMD.getServiceRefType(); - if (targetClassName == null) - targetClassName = (String) ref.get(ServiceReferenceable.TARGET_CLASS_NAME).getContent(); - - if (Service.class.getName().equals(targetClassName)) - targetClassName = serviceImplClass; - - return targetClassName; - } - - private Object instantiatePort(final Class<?> serviceClass, final Class<?> targetClass, final Service target, - final QName portQName, final WebServiceFeature[] features) throws NoSuchMethodException, - InstantiationException, IllegalAccessException, InvocationTargetException - { - Object retVal = null; - - Object port = null; - if (serviceClass != Service.class) - { - for (Method method : serviceClass.getDeclaredMethods()) - { - String methodName = method.getName(); - Class<?> retType = method.getReturnType(); - if (methodName.startsWith("get") && targetClass.isAssignableFrom(retType)) - { - port = method.invoke(target, new Object[0]); - retVal = port; - break; - } - } - } - - if (port == null) - { - Method method = getMethodFor(portQName, features, serviceClass); - Object[] args = getArgumentsFor(portQName, features, targetClass); - port = method.invoke(target, args); - retVal = port; - } - - return retVal; - } - - private Service instantiateService(final UnifiedServiceRefMetaData serviceRefMD, final Class<?> serviceClass) - throws NoSuchMethodException, InstantiationException, IllegalAccessException, InvocationTargetException - { - final WebServiceFeature[] features = getFeatures(serviceRefMD); - final URL wsdlURL = serviceRefMD.getWsdlLocation(); - final QName serviceQName = serviceRefMD.getServiceQName(); - - Service target = null; - if (serviceClass == Service.class) - { - // Generic javax.xml.ws.Service - if (wsdlURL != null) - { - if (features != null) - { - target = Service.create(wsdlURL, serviceQName, features); - } - else - { - target = Service.create(wsdlURL, serviceQName); - } - } - else - { - throw new IllegalArgumentException("Cannot create generic javax.xml.ws.Service without wsdlLocation: " - + serviceRefMD); - } - } - else - { - // Generated javax.xml.ws.Service subclass - if (wsdlURL != null) - { - if (features != null) - { - Constructor<?> ctor = serviceClass.getConstructor(new Class[] - {URL.class, QName.class, WebServiceFeature[].class}); - target = (Service) ctor.newInstance(new Object[] - {wsdlURL, serviceQName, features}); - } - else - { - Constructor<?> ctor = serviceClass.getConstructor(new Class[] - {URL.class, QName.class}); - target = (Service) ctor.newInstance(new Object[] - {wsdlURL, serviceQName}); - } - } - else - { - if (features != null) - { - Constructor<?> ctor = serviceClass.getConstructor(new Class[] - {WebServiceFeature[].class}); - target = (Service) ctor.newInstance(new Object[] - {features}); - } - else - { - target = (Service) serviceClass.newInstance(); - } - } - } - - return target; - } - - private WebServiceFeature[] getFeatures(final String targetClassName, final String serviceClassName, - final UnifiedServiceRefMetaData serviceRefMD) - { - if (targetClassName != null && !targetClassName.equals(serviceClassName)) - { - final Collection<UnifiedPortComponentRefMetaData> portComponentRefs = serviceRefMD.getPortComponentRefs(); - for (final UnifiedPortComponentRefMetaData portComponentRefMD : portComponentRefs) - { - if (targetClassName.equals(portComponentRefMD.getServiceEndpointInterface())) - { - return getFeatures(portComponentRefMD); - } - } - } - - return null; - } - - private QName getPortQName(final String targetClassName, final String serviceClassName, - final UnifiedServiceRefMetaData serviceRefMD) - { - if (targetClassName != null && !targetClassName.equals(serviceClassName)) - { - final Collection<UnifiedPortComponentRefMetaData> portComponentRefs = serviceRefMD.getPortComponentRefs(); - for (final UnifiedPortComponentRefMetaData portComponentRefMD : portComponentRefs) - { - if (targetClassName.equals(portComponentRefMD.getServiceEndpointInterface())) - { - return portComponentRefMD.getPortQName(); - } - } - } - - return null; - } - - private Method getMethodFor(final QName portQName, final WebServiceFeature[] features, final Class<?> serviceClass) - throws NoSuchMethodException - { - if ((portQName == null) && (features == null)) - return serviceClass.getMethod("getPort", new Class[] - {Class.class}); - if ((portQName != null) && (features == null)) - return serviceClass.getMethod("getPort", new Class[] - {QName.class, Class.class}); - if ((portQName == null) && (features != null)) - return serviceClass.getMethod("getPort", new Class[] - {Class.class, WebServiceFeature[].class}); - if ((portQName != null) && (features != null)) - return serviceClass.getMethod("getPort", new Class[] - {QName.class, Class.class, WebServiceFeature[].class}); - - throw new IllegalStateException(); - } - - private Object[] getArgumentsFor(final QName portQName, final WebServiceFeature[] features, - final Class<?> targetClass) throws NoSuchMethodException - { - if ((portQName == null) && (features == null)) - return new Object[] - {targetClass}; - if ((portQName != null) && (features == null)) - return new Object[] - {portQName, targetClass}; - if ((portQName == null) && (features != null)) - return new Object[] - {targetClass, features}; - if ((portQName != null) && (features != null)) - return new Object[] - {portQName, targetClass, features}; - - throw new IllegalStateException(); - } - - private WebServiceFeature[] getFeatures(final UnifiedServiceRefMetaData serviceRef) - { - List<WebServiceFeature> features = new LinkedList<WebServiceFeature>(); - - // configure @Addressing feature - if (serviceRef.isAddressingEnabled()) - { - final boolean required = serviceRef.isAddressingRequired(); - final String refResponses = serviceRef.getAddressingResponses(); - AddressingFeature.Responses responses = AddressingFeature.Responses.ALL; - if ("ANONYMOUS".equals(refResponses)) - responses = AddressingFeature.Responses.ANONYMOUS; - if ("NON_ANONYMOUS".equals(refResponses)) - responses = AddressingFeature.Responses.NON_ANONYMOUS; - - features.add(new AddressingFeature(true, required, responses)); - } - - // configure @MTOM feature - if (serviceRef.isMtomEnabled()) - { - features.add(new MTOMFeature(true, serviceRef.getMtomThreshold())); - } - - // configure @RespectBinding feature - if (serviceRef.isRespectBindingEnabled()) - { - features.add(new RespectBindingFeature(true)); - } - - WebServiceFeature[] wsFeatures = features.size() == 0 ? null : features.toArray(new WebServiceFeature[] - {}); - return wsFeatures; - } - - private WebServiceFeature[] getFeatures(final UnifiedPortComponentRefMetaData portComponentRefMD) - { - List<WebServiceFeature> features = new LinkedList<WebServiceFeature>(); - // configure @Addressing feature - if (portComponentRefMD.isAddressingEnabled()) - { - final boolean required = portComponentRefMD.isAddressingRequired(); - final String refResponses = portComponentRefMD.getAddressingResponses(); - AddressingFeature.Responses responses = AddressingFeature.Responses.ALL; - if ("ANONYMOUS".equals(refResponses)) - responses = AddressingFeature.Responses.ANONYMOUS; - if ("NON_ANONYMOUS".equals(refResponses)) - responses = AddressingFeature.Responses.NON_ANONYMOUS; - - features.add(new AddressingFeature(true, required, responses)); - } - - // configure @MTOM feature - if (portComponentRefMD.isMtomEnabled()) - { - features.add(new MTOMFeature(true, portComponentRefMD.getMtomThreshold())); - } - - // configure @RespectBinding feature - if (portComponentRefMD.isRespectBindingEnabled()) - { - features.add(new RespectBindingFeature(true)); - } - - return features.size() == 0 ? null : features.toArray(new WebServiceFeature[] - {}); - } - - private UnifiedServiceRefMetaData unmarshallServiceRef(final Reference ref) throws ClassNotFoundException, - NamingException - { - final UnifiedServiceRefMetaData sref; - final RefAddr refAddr = ref.get(ServiceReferenceable.SERVICE_REF_META_DATA); - final ByteArrayInputStream bais = new ByteArrayInputStream((byte[]) refAddr.getContent()); - try - { - ObjectInputStream ois = new ObjectInputStream(bais); - sref = (UnifiedServiceRefMetaData) ois.readObject(); - ois.close(); - } - catch (IOException e) - { - throw new NamingException("Cannot unmarshall service ref meta data, cause: " + e.toString()); - } - - return sref; - } -} Deleted: stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/ServiceReferenceable.java =================================================================== --- stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/ServiceReferenceable.java 2010-10-15 12:43:36 UTC (rev 13136) +++ stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/client/ServiceReferenceable.java 2010-10-15 12:46:51 UTC (rev 13137) @@ -1,104 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * Copyright 2006, Red Hat Middleware LLC, and individual contributors - * as indicated by the @author tags. See the copyright.txt file in the - * distribution for a full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jboss.ws.core.jaxws.client; - -import java.io.ByteArrayOutputStream; -import java.io.IOException; -import java.io.ObjectOutputStream; - -import javax.naming.BinaryRefAddr; -import javax.naming.NamingException; -import javax.naming.Reference; -import javax.naming.Referenceable; -import javax.naming.StringRefAddr; - -import org.jboss.wsf.spi.metadata.j2ee.serviceref.UnifiedServiceRefMetaData; - - -/** - * A JNDI reference to a javax.xml.ws.Service - * - * It holds the information to reconstrut the javax.xml.ws.Service - * when the client does a JNDI lookup. - * - * @author Thomas.Diesler(a)jboss.org - * @since 24-Oct-2006 - */ -public class ServiceReferenceable implements Referenceable -{ - public static final String SERVICE_REF_META_DATA = "SERVICE_REF_META_DATA"; - public static final String SERVICE_IMPL_CLASS = "SERVICE_CLASS_NAME"; - public static final String TARGET_CLASS_NAME = "TARGET_CLASS_NAME"; - - private String serviceImplClass; - private String targetClassName; - private UnifiedServiceRefMetaData serviceRef; - - public ServiceReferenceable(String serviceImplClass, String targetClassName, UnifiedServiceRefMetaData serviceRef) - { - this.serviceImplClass = serviceImplClass; - this.targetClassName = targetClassName; - this.serviceRef = serviceRef; - } - - /** - * Retrieves the Reference of this object. - * - * @return The non-null Reference of this object. - * @throws javax.naming.NamingException If a naming exception was encountered while retrieving the reference. - */ - public Reference getReference() throws NamingException - { - Reference myRef = new Reference(ServiceReferenceable.class.getName(), ServiceObjectFactoryJAXWS.class.getName(), null); - - myRef.add(new StringRefAddr(SERVICE_IMPL_CLASS, serviceImplClass)); - myRef.add(new StringRefAddr(TARGET_CLASS_NAME, targetClassName)); - myRef.add(new BinaryRefAddr(SERVICE_REF_META_DATA, marshall(serviceRef))); - - return myRef; - } - - private byte[] marshall(Object obj) throws NamingException - { - ByteArrayOutputStream baos = new ByteArrayOutputStream(512); - try - { - ObjectOutputStream oos = new ObjectOutputStream(baos); - oos.writeObject(obj); - oos.close(); - } - catch (IOException e) - { - throw new NamingException("Cannot marshall object, cause: " + e.toString()); - } - return baos.toByteArray(); - } - - public String toString() { - final StringBuilder sb = new StringBuilder(); - sb.append("\n").append(getClass().getName()); - sb.append("\n serviceImplClass=" + serviceImplClass); - sb.append("\n targetClassName=" + targetClassName); - sb.append("\n serviceRef=" + this.serviceRef); - return sb.toString(); - } -} Modified: stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/spi/ServiceDelegateImpl.java =================================================================== --- stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/spi/ServiceDelegateImpl.java 2010-10-15 12:43:36 UTC (rev 13136) +++ stack/native/trunk/modules/core/src/main/java/org/jboss/ws/core/jaxws/spi/ServiceDelegateImpl.java 2010-10-15 12:46:51 UTC (rev 13137) @@ -60,7 +60,7 @@ import org.jboss.ws.core.jaxws.client.ClientImpl; import org.jboss.ws.core.jaxws.client.ClientProxy; import org.jboss.ws.core.jaxws.client.DispatchImpl; -import org.jboss.ws.core.jaxws.client.ServiceObjectFactoryJAXWS; +import org.jboss.ws.core.jaxws.client.NativeServiceObjectFactoryJAXWS; import org.jboss.ws.core.jaxws.handler.HandlerResolverImpl; import org.jboss.ws.core.jaxws.wsaddressing.EndpointReferenceUtil; import org.jboss.ws.core.jaxws.wsaddressing.NativeEndpointReference; @@ -130,7 +130,7 @@ { // If this Service was constructed through the ServiceObjectFactory // this thread local association should be available - usRef = ServiceObjectFactoryJAXWS.getServiceRefAssociation(); + usRef = NativeServiceObjectFactoryJAXWS.getServiceRefAssociation(); UnifiedVirtualFile vfsRoot = (usRef != null ? vfsRoot = usRef.getVfsRoot() : new ResourceLoaderAdapter()); // Verify wsdl access if this is not a generic Service Modified: stack/native/trunk/modules/core/src/main/java/org/jboss/ws/metadata/builder/jaxws/JAXWSClientMetaDataBuilder.java =================================================================== --- stack/native/trunk/modules/core/src/main/java/org/jboss/ws/metadata/builder/jaxws/JAXWSClientMetaDataBuilder.java 2010-10-15 12:43:36 UTC (rev 13136) +++ stack/native/trunk/modules/core/src/main/java/org/jboss/ws/metadata/builder/jaxws/JAXWSClientMetaDataBuilder.java 2010-10-15 12:46:51 UTC (rev 13137) @@ -35,7 +35,7 @@ import org.jboss.ws.Constants; import org.jboss.ws.WSException; import org.jboss.ws.annotation.EndpointConfig; -import org.jboss.ws.core.jaxws.client.ServiceObjectFactoryJAXWS; +import org.jboss.ws.core.jaxws.client.NativeServiceObjectFactoryJAXWS; import org.jboss.ws.core.jaxws.wsaddressing.NativeEndpointReference; import org.jboss.ws.extensions.policy.metadata.PolicyMetaDataBuilder; import org.jboss.ws.extensions.wsrm.common.RMHelper; @@ -219,7 +219,7 @@ */ private void bufferServiceRefContributions(EndpointMetaData epMetaData) { - UnifiedServiceRefMetaData serviceRefMetaData = ServiceObjectFactoryJAXWS.getServiceRefAssociation(); + UnifiedServiceRefMetaData serviceRefMetaData = NativeServiceObjectFactoryJAXWS.getServiceRefAssociation(); if (serviceRefMetaData != null) {