rpcbinding.java

来自「Xfire文件 用于开发web service 的一个开源工具 很好用的」· Java 代码 · 共 111 行

package org.codehaus.xfire.service.binding;

import java.util.ArrayList;
import java.util.List;

import javax.xml.namespace.QName;

import org.codehaus.xfire.MessageContext;
import org.codehaus.xfire.exchange.InMessage;
import org.codehaus.xfire.fault.XFireFault;
import org.codehaus.xfire.service.MessageInfo;
import org.codehaus.xfire.service.MessagePartInfo;
import org.codehaus.xfire.service.OperationInfo;
import org.codehaus.xfire.service.Service;
import org.codehaus.xfire.soap.AbstractSoapBinding;
import org.codehaus.xfire.soap.SoapConstants;
import org.codehaus.xfire.util.STAXUtils;
import org.codehaus.xfire.util.stax.DepthXMLStreamReader;

public class RPCBinding
    extends WrappedBinding
{
    public RPCBinding()
    {
    }

    public void readMessage(InMessage inMessage, MessageContext context)
        throws XFireFault
    {
        Service endpoint = context.getService();
        
        List parameters = new ArrayList();
        DepthXMLStreamReader dr = new DepthXMLStreamReader(context.getInMessage().getXMLStreamReader());
        
        if ( !STAXUtils.toNextElement(dr) )
            throw new XFireFault("There must be a method name element.", XFireFault.SENDER);
        
        String opName = dr.getLocalName();
        if (isClientModeOn(context))
            opName = opName.substring(0, opName.lastIndexOf("Response"));
        
        OperationInfo operation = endpoint.getServiceInfo().getOperation( opName );

        if (operation == null)
            throw new XFireFault("Could not find operation: " + opName, XFireFault.SENDER);
        
        // Move from operation element to whitespace or start element
        nextEvent(dr);
        
        setOperation(operation, context);

        if (operation == null)
        {
            throw new XFireFault("Invalid operation.", XFireFault.SENDER);
        }

        Service service = context.getService();
        
        MessageInfo msg;
        if (isClientModeOn(context))
            msg = operation.getOutputMessage();
        else
            msg = operation.getInputMessage();
        
        while(STAXUtils.toNextElement(dr))
        {
            MessagePartInfo p = (MessagePartInfo) msg.getMessageParts().get(parameters.size());

            if (p == null)
            {
                throw new XFireFault("Parameter " + dr.getName() + " does not exist!", 
                                     XFireFault.SENDER);
            }
            
            QName name;
            if (p.getSchemaType().isAbstract())
            {
                name = new QName(service.getTargetNamespace(), dr.getLocalName());
            }
            else
            {
                name = dr.getName();
            }
            
            if (!p.getName().equals(name))
            {
                throw new XFireFault("Parameter " + dr.getName() + " does not exist!", 
                                     XFireFault.SENDER);
            }
            
            parameters.add( endpoint.getBindingProvider().readParameter(p, dr, context) );
        }
        
        context.getInMessage().setBody(parameters);
    }

    protected String getBoundNamespace(MessageContext context, MessagePartInfo p)
    {
        if (p.isSchemaElement() ||
                ((AbstractSoapBinding) context.getBinding()).getUse().equals(SoapConstants.USE_ENCODED))
            return p.getName().getNamespaceURI();
        else
            return "";
    }

    public Object clone()
    {
        return new RPCBinding();
    }    
}