resourcemanagerwssei_tie.java

这是一个基于计算网格的web service。它用java编写。一旦安装完成

// This class was generated by the JAXRPC SI, do not edit.
// Contents subject to change without notice.
// JAX-RPC Standard Implementation (1.1.2_02, build R41)
// Generated source version: 1.1.2

package jwsgrid.resourcemanager.ws;

import com.sun.xml.rpc.server.http.MessageContextProperties;
import com.sun.xml.rpc.streaming.*;
import com.sun.xml.rpc.encoding.*;
import com.sun.xml.rpc.encoding.soap.SOAPConstants;
import com.sun.xml.rpc.encoding.soap.SOAP12Constants;
import com.sun.xml.rpc.encoding.literal.*;
import com.sun.xml.rpc.soap.streaming.*;
import com.sun.xml.rpc.soap.message.*;
import com.sun.xml.rpc.soap.SOAPVersion;
import com.sun.xml.rpc.soap.SOAPEncodingConstants;
import com.sun.xml.rpc.wsdl.document.schema.SchemaConstants;
import javax.xml.namespace.QName;
import java.rmi.RemoteException;
import java.util.Iterator;
import java.lang.reflect.*;
import java.lang.Class;
import com.sun.xml.rpc.server.*;
import javax.xml.rpc.handler.HandlerInfo;
import com.sun.xml.rpc.client.HandlerChainImpl;

public class ResourceManagerWSSEI_Tie
    extends com.sun.xml.rpc.server.TieBase implements SerializerConstants {
    
    
    
    public ResourceManagerWSSEI_Tie() throws Exception {
        super(new jwsgrid.resourcemanager.ws.ResourceManagerWS_SerializerRegistry().getRegistry());
        initialize(internalTypeMappingRegistry);
    }
    
    /*
     * This method does the actual method invocation for operation: searchJobHosts
     */
    private void invoke_searchJobHosts(StreamingHandlerState state) throws Exception {
        
        jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_searchJobHosts_RequestStruct myResourceManagerWSSEI_searchJobHosts_RequestStruct = null;
        Object myResourceManagerWSSEI_searchJobHosts_RequestStructObj =
            state.getRequest().getBody().getValue();
        
        if (myResourceManagerWSSEI_searchJobHosts_RequestStructObj instanceof SOAPDeserializationState) {
            myResourceManagerWSSEI_searchJobHosts_RequestStruct = (jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_searchJobHosts_RequestStruct)((SOAPDeserializationState)myResourceManagerWSSEI_searchJobHosts_RequestStructObj).getInstance();
        } else {
            myResourceManagerWSSEI_searchJobHosts_RequestStruct = (jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_searchJobHosts_RequestStruct)myResourceManagerWSSEI_searchJobHosts_RequestStructObj;
        }
        
        try {
            java.lang.String result = ((jwsgrid.resourcemanager.ws.ResourceManagerWSSEI) getTarget()).searchJobHosts(myResourceManagerWSSEI_searchJobHosts_RequestStruct.getString_1());
            
            SOAPHeaderBlockInfo headerInfo;
            
            
            jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_searchJobHosts_ResponseStruct _response = new jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_searchJobHosts_ResponseStruct();
            _response.setResult(result);
            SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_searchJobHosts_searchJobHostsResponse_QNAME);
            bodyBlock.setValue(_response);
            bodyBlock.setSerializer(ns1_myResourceManagerWSSEI_searchJobHosts_ResponseStruct_LiteralSerializer);
            state.getResponse().setBody(bodyBlock);
        } catch (jwsgrid.resourcemanager.ws.ConstraintDistanceException e) {
            SOAPFaultInfo fault = new SOAPFaultInfo(com.sun.xml.rpc.encoding.soap.SOAPConstants.FAULT_CODE_SERVER,
                "jwsgrid.resourcemanager.ws.ConstraintDistanceException", null, e);
            SOAPBlockInfo faultBlock = new SOAPBlockInfo(com.sun.xml.rpc.encoding.soap.SOAPConstants.QNAME_SOAP_FAULT);
            faultBlock.setValue(fault);
            faultBlock.setSerializer(myResourceManagerWSSEI_searchJobHosts_Fault_SOAPSerializer);
            state.getResponse().setBody(faultBlock);
            state.getResponse().setFailure(true);
        } catch (jwsgrid.resourcemanager.ws.ConstraintMatchException e) {
            SOAPFaultInfo fault = new SOAPFaultInfo(com.sun.xml.rpc.encoding.soap.SOAPConstants.FAULT_CODE_SERVER,
                "jwsgrid.resourcemanager.ws.ConstraintMatchException", null, e);
            SOAPBlockInfo faultBlock = new SOAPBlockInfo(com.sun.xml.rpc.encoding.soap.SOAPConstants.QNAME_SOAP_FAULT);
            faultBlock.setValue(fault);
            faultBlock.setSerializer(myResourceManagerWSSEI_searchJobHosts_Fault_SOAPSerializer);
            state.getResponse().setBody(faultBlock);
            state.getResponse().setFailure(true);
        } catch (javax.xml.rpc.soap.SOAPFaultException e) {
            SOAPFaultInfo fault = new SOAPFaultInfo(e.getFaultCode(),
                e.getFaultString(), e.getFaultActor(), e.getDetail());
            SOAPBlockInfo faultBlock = new SOAPBlockInfo(com.sun.xml.rpc.encoding.soap.SOAPConstants.QNAME_SOAP_FAULT);
            faultBlock.setValue(fault);
            faultBlock.setSerializer(new SOAPFaultInfoSerializer(false, e.getDetail()==null));
            state.getResponse().setBody(faultBlock);
            state.getResponse().setFailure(true);
        }
    }
    
    /*
     * This method does the actual method invocation for operation: registerJobHost
     */
    private void invoke_registerJobHost(StreamingHandlerState state) throws Exception {
        
        jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_registerJobHost_RequestStruct myResourceManagerWSSEI_registerJobHost_RequestStruct = null;
        Object myResourceManagerWSSEI_registerJobHost_RequestStructObj =
            state.getRequest().getBody().getValue();
        
        if (myResourceManagerWSSEI_registerJobHost_RequestStructObj instanceof SOAPDeserializationState) {
            myResourceManagerWSSEI_registerJobHost_RequestStruct = (jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_registerJobHost_RequestStruct)((SOAPDeserializationState)myResourceManagerWSSEI_registerJobHost_RequestStructObj).getInstance();
        } else {
            myResourceManagerWSSEI_registerJobHost_RequestStruct = (jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_registerJobHost_RequestStruct)myResourceManagerWSSEI_registerJobHost_RequestStructObj;
        }
        
        try {
            ((jwsgrid.resourcemanager.ws.ResourceManagerWSSEI) getTarget()).registerJobHost(myResourceManagerWSSEI_registerJobHost_RequestStruct.getString_1(), myResourceManagerWSSEI_registerJobHost_RequestStruct.getString_2(), myResourceManagerWSSEI_registerJobHost_RequestStruct.getString_3(), myResourceManagerWSSEI_registerJobHost_RequestStruct.getString_4());
            
            SOAPHeaderBlockInfo headerInfo;
            
            
            jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_registerJobHost_ResponseStruct _response = new jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_registerJobHost_ResponseStruct();
            SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_registerJobHost_registerJobHostResponse_QNAME);
            bodyBlock.setValue(_response);
            bodyBlock.setSerializer(ns1_myResourceManagerWSSEI_registerJobHost_ResponseStruct_LiteralSerializer);
            state.getResponse().setBody(bodyBlock);
        } catch (javax.xml.rpc.soap.SOAPFaultException e) {
            SOAPFaultInfo fault = new SOAPFaultInfo(e.getFaultCode(),
                e.getFaultString(), e.getFaultActor(), e.getDetail());
            SOAPBlockInfo faultBlock = new SOAPBlockInfo(com.sun.xml.rpc.encoding.soap.SOAPConstants.QNAME_SOAP_FAULT);
            faultBlock.setValue(fault);
            faultBlock.setSerializer(new SOAPFaultInfoSerializer(false, e.getDetail()==null));
            state.getResponse().setBody(faultBlock);
            state.getResponse().setFailure(true);
        }
    }
    
    /*
     * This method does the actual method invocation for operation: ping
     */
    private void invoke_ping(StreamingHandlerState state) throws Exception {
        
        jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_ping_RequestStruct myResourceManagerWSSEI_ping_RequestStruct = null;
        Object myResourceManagerWSSEI_ping_RequestStructObj =
            state.getRequest().getBody().getValue();
        
        if (myResourceManagerWSSEI_ping_RequestStructObj instanceof SOAPDeserializationState) {
            myResourceManagerWSSEI_ping_RequestStruct = (jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_ping_RequestStruct)((SOAPDeserializationState)myResourceManagerWSSEI_ping_RequestStructObj).getInstance();
        } else {
            myResourceManagerWSSEI_ping_RequestStruct = (jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_ping_RequestStruct)myResourceManagerWSSEI_ping_RequestStructObj;
        }
        
        try {
            long result = ((jwsgrid.resourcemanager.ws.ResourceManagerWSSEI) getTarget()).ping();
            
            SOAPHeaderBlockInfo headerInfo;
            
            
            jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_ping_ResponseStruct _response = new jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_ping_ResponseStruct();
            _response.setResult(result);
            SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_ping_pingResponse_QNAME);
            bodyBlock.setValue(_response);
            bodyBlock.setSerializer(ns1_myResourceManagerWSSEI_ping_ResponseStruct_LiteralSerializer);
            state.getResponse().setBody(bodyBlock);
        } catch (javax.xml.rpc.soap.SOAPFaultException e) {
            SOAPFaultInfo fault = new SOAPFaultInfo(e.getFaultCode(),
                e.getFaultString(), e.getFaultActor(), e.getDetail());
            SOAPBlockInfo faultBlock = new SOAPBlockInfo(com.sun.xml.rpc.encoding.soap.SOAPConstants.QNAME_SOAP_FAULT);
            faultBlock.setValue(fault);
            faultBlock.setSerializer(new SOAPFaultInfoSerializer(false, e.getDetail()==null));
            state.getResponse().setBody(faultBlock);
            state.getResponse().setFailure(true);
        }
    }
    
    /*
     * This method does the actual method invocation for operation: unregisterJobHost
     */
    private void invoke_unregisterJobHost(StreamingHandlerState state) throws Exception {
        
        jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_unregisterJobHost_RequestStruct myResourceManagerWSSEI_unregisterJobHost_RequestStruct = null;
        Object myResourceManagerWSSEI_unregisterJobHost_RequestStructObj =
            state.getRequest().getBody().getValue();
        
        if (myResourceManagerWSSEI_unregisterJobHost_RequestStructObj instanceof SOAPDeserializationState) {
            myResourceManagerWSSEI_unregisterJobHost_RequestStruct = (jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_unregisterJobHost_RequestStruct)((SOAPDeserializationState)myResourceManagerWSSEI_unregisterJobHost_RequestStructObj).getInstance();
        } else {
            myResourceManagerWSSEI_unregisterJobHost_RequestStruct = (jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_unregisterJobHost_RequestStruct)myResourceManagerWSSEI_unregisterJobHost_RequestStructObj;
        }
        
        try {
            boolean result = ((jwsgrid.resourcemanager.ws.ResourceManagerWSSEI) getTarget()).unregisterJobHost(myResourceManagerWSSEI_unregisterJobHost_RequestStruct.getString_1(), myResourceManagerWSSEI_unregisterJobHost_RequestStruct.getString_2());
            
            SOAPHeaderBlockInfo headerInfo;
            
            
            jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_unregisterJobHost_ResponseStruct _response = new jwsgrid.resourcemanager.ws.ResourceManagerWSSEI_unregisterJobHost_ResponseStruct();
            _response.setResult(result);
            SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_unregisterJobHost_unregisterJobHostResponse_QNAME);
            bodyBlock.setValue(_response);
            bodyBlock.setSerializer(ns1_myResourceManagerWSSEI_unregisterJobHost_ResponseStruct_LiteralSerializer);
            state.getResponse().setBody(bodyBlock);
        } catch (javax.xml.rpc.soap.SOAPFaultException e) {
            SOAPFaultInfo fault = new SOAPFaultInfo(e.getFaultCode(),
                e.getFaultString(), e.getFaultActor(), e.getDetail());
            SOAPBlockInfo faultBlock = new SOAPBlockInfo(com.sun.xml.rpc.encoding.soap.SOAPConstants.QNAME_SOAP_FAULT);
            faultBlock.setValue(fault);
            faultBlock.setSerializer(new SOAPFaultInfoSerializer(false, e.getDetail()==null));
            state.getResponse().setBody(faultBlock);
            state.getResponse().setFailure(true);
        }
    }
    
    /*
     * This method must determine the opcode of the operation that has been invoked.
     */
    protected void peekFirstBodyElement(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        if (bodyReader.getName().equals(ns1_searchJobHosts_searchJobHosts_QNAME)) {
            state.getRequest().setOperationCode(searchJobHosts_OPCODE);
        }
        else if (bodyReader.getName().equals(ns1_registerJobHost_registerJobHost_QNAME)) {
            state.getRequest().setOperationCode(registerJobHost_OPCODE);
        }
        else if (bodyReader.getName().equals(ns1_ping_ping_QNAME)) {
            state.getRequest().setOperationCode(ping_OPCODE);
        }
        else if (bodyReader.getName().equals(ns1_unregisterJobHost_unregisterJobHost_QNAME)) {
            state.getRequest().setOperationCode(unregisterJobHost_OPCODE);
        }
        else {
            throw new SOAPProtocolViolationException("soap.operation.unrecognized", bodyReader.getName().toString());
        }
    }
    
    /*
     *  this method deserializes the request/response structure in the body
     */
    protected void readFirstBodyElement(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState  state) throws Exception {
        int opcode = state.getRequest().getOperationCode();
        switch (opcode) {
            case searchJobHosts_OPCODE:
                deserialize_searchJobHosts(bodyReader, deserializationContext, state);
                break;
            case registerJobHost_OPCODE:
                deserialize_registerJobHost(bodyReader, deserializationContext, state);
                break;
            case ping_OPCODE:
                deserialize_ping(bodyReader, deserializationContext, state);
                break;
            case unregisterJobHost_OPCODE: