| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package org.apache.commons.proxy.provider.remoting; |
| |
| import org.apache.commons.proxy.ObjectProvider; |
| import org.apache.commons.proxy.exception.ObjectProviderException; |
| |
| import javax.xml.namespace.QName; |
| import javax.xml.rpc.Service; |
| import javax.xml.rpc.ServiceException; |
| import javax.xml.rpc.ServiceFactory; |
| import java.net.MalformedURLException; |
| import java.net.URL; |
| |
| /** |
| * Returns a proxy for a JAX-RPC-based service. |
| * |
| * <p> |
| * <b>Dependencies</b>: |
| * <ul> |
| * <li>A JAX-RPC implementation</li> |
| * </ul> |
| * </p> |
| * @author James Carman |
| * @since 1.0 |
| */ |
| public class JaxRpcProvider implements ObjectProvider |
| { |
| //---------------------------------------------------------------------------------------------------------------------- |
| // Fields |
| //---------------------------------------------------------------------------------------------------------------------- |
| |
| private Class serviceInterface; |
| private String wsdlUrl; |
| private String serviceNamespaceUri; |
| private String serviceLocalPart; |
| private String servicePrefix; |
| private String portNamespaceUri; |
| private String portLocalPart; |
| private String portPrefix; |
| |
| //---------------------------------------------------------------------------------------------------------------------- |
| // Constructors |
| //---------------------------------------------------------------------------------------------------------------------- |
| |
| public JaxRpcProvider() |
| { |
| } |
| |
| public JaxRpcProvider( Class serviceInterface ) |
| { |
| this.serviceInterface = serviceInterface; |
| } |
| |
| //---------------------------------------------------------------------------------------------------------------------- |
| // ObjectProvider Implementation |
| //---------------------------------------------------------------------------------------------------------------------- |
| |
| public Object getObject() |
| { |
| try |
| { |
| final Service service = ( wsdlUrl == null ? |
| ServiceFactory.newInstance().createService( getServiceQName() ) : ServiceFactory |
| .newInstance().createService( new URL( wsdlUrl ), getServiceQName() ) ); |
| final QName portQName = getPortQName(); |
| return portQName == null ? service.getPort( serviceInterface ) : |
| service.getPort( portQName, serviceInterface ); |
| } |
| catch( ServiceException e ) |
| { |
| throw new ObjectProviderException( "Unable to create JAX-RPC service proxy.", e ); |
| } |
| catch( MalformedURLException e ) |
| { |
| throw new ObjectProviderException( "Invalid URL given.", e ); |
| } |
| } |
| |
| //---------------------------------------------------------------------------------------------------------------------- |
| // Getter/Setter Methods |
| //---------------------------------------------------------------------------------------------------------------------- |
| |
| public void setPortLocalPart( String portLocalPart ) |
| { |
| this.portLocalPart = portLocalPart; |
| } |
| |
| public void setPortNamespaceUri( String portNamespaceUri ) |
| { |
| this.portNamespaceUri = portNamespaceUri; |
| } |
| |
| public void setPortPrefix( String portPrefix ) |
| { |
| this.portPrefix = portPrefix; |
| } |
| |
| public void setServiceInterface( Class serviceInterface ) |
| { |
| this.serviceInterface = serviceInterface; |
| } |
| |
| public void setServiceLocalPart( String serviceLocalPart ) |
| { |
| this.serviceLocalPart = serviceLocalPart; |
| } |
| |
| public void setServiceNamespaceUri( String serviceNamespaceUri ) |
| { |
| this.serviceNamespaceUri = serviceNamespaceUri; |
| } |
| |
| public void setServicePrefix( String servicePrefix ) |
| { |
| this.servicePrefix = servicePrefix; |
| } |
| |
| public void setWsdlUrl( String wsdlUrl ) |
| { |
| this.wsdlUrl = wsdlUrl; |
| } |
| |
| //---------------------------------------------------------------------------------------------------------------------- |
| // Other Methods |
| //---------------------------------------------------------------------------------------------------------------------- |
| |
| private QName getPortQName() |
| { |
| return getQName( portNamespaceUri, portLocalPart, portPrefix ); |
| } |
| |
| private QName getQName( String namespaceUri, String localPart, String prefix ) |
| { |
| if( namespaceUri != null && localPart != null && prefix != null ) |
| { |
| return new QName( namespaceUri, localPart, prefix ); |
| } |
| else if( namespaceUri != null && localPart != null ) |
| { |
| return new QName( namespaceUri, localPart ); |
| } |
| else if( localPart != null ) |
| { |
| return new QName( localPart ); |
| } |
| return null; |
| } |
| |
| private QName getServiceQName() |
| { |
| return getQName( serviceNamespaceUri, serviceLocalPart, servicePrefix ); |
| } |
| } |
| |