jobhostwssei_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.jobhost.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 JobHostWSSEI_Tie
    extends com.sun.xml.rpc.server.TieBase implements SerializerConstants {
    
    
    
    public JobHostWSSEI_Tie() throws Exception {
        super(new jwsgrid.jobhost.ws.JobHostWS_SerializerRegistry().getRegistry());
        initialize(internalTypeMappingRegistry);
    }
    
    /*
     * This method does the actual method invocation for operation: stopJob
     */
    private void invoke_stopJob(StreamingHandlerState state) throws Exception {
        
        jwsgrid.jobhost.ws.JobHostWSSEI_stopJob_RequestStruct myJobHostWSSEI_stopJob_RequestStruct = null;
        Object myJobHostWSSEI_stopJob_RequestStructObj =
            state.getRequest().getBody().getValue();
        
        if (myJobHostWSSEI_stopJob_RequestStructObj instanceof SOAPDeserializationState) {
            myJobHostWSSEI_stopJob_RequestStruct = (jwsgrid.jobhost.ws.JobHostWSSEI_stopJob_RequestStruct)((SOAPDeserializationState)myJobHostWSSEI_stopJob_RequestStructObj).getInstance();
        } else {
            myJobHostWSSEI_stopJob_RequestStruct = (jwsgrid.jobhost.ws.JobHostWSSEI_stopJob_RequestStruct)myJobHostWSSEI_stopJob_RequestStructObj;
        }
        
        try {
            ((jwsgrid.jobhost.ws.JobHostWSSEI) getTarget()).stopJob(myJobHostWSSEI_stopJob_RequestStruct.getString_1(), myJobHostWSSEI_stopJob_RequestStruct.getString_2());
            jwsgrid.jobhost.ws.JobHostWSSEI_stopJob_ResponseStruct myJobHostWSSEI_stopJob_ResponseStruct =
                new jwsgrid.jobhost.ws.JobHostWSSEI_stopJob_ResponseStruct();
            SOAPHeaderBlockInfo headerInfo;
            
            SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_stopJob_stopJobResponse_QNAME);
            bodyBlock.setValue(myJobHostWSSEI_stopJob_ResponseStruct);
            bodyBlock.setSerializer(ns2_myJobHostWSSEI_stopJob_ResponseStruct_SOAPSerializer);
            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: getDynamicInfo
     */
    private void invoke_getDynamicInfo(StreamingHandlerState state) throws Exception {
        
        jwsgrid.jobhost.ws.JobHostWSSEI_getDynamicInfo_RequestStruct myJobHostWSSEI_getDynamicInfo_RequestStruct = null;
        Object myJobHostWSSEI_getDynamicInfo_RequestStructObj =
            state.getRequest().getBody().getValue();
        
        if (myJobHostWSSEI_getDynamicInfo_RequestStructObj instanceof SOAPDeserializationState) {
            myJobHostWSSEI_getDynamicInfo_RequestStruct = (jwsgrid.jobhost.ws.JobHostWSSEI_getDynamicInfo_RequestStruct)((SOAPDeserializationState)myJobHostWSSEI_getDynamicInfo_RequestStructObj).getInstance();
        } else {
            myJobHostWSSEI_getDynamicInfo_RequestStruct = (jwsgrid.jobhost.ws.JobHostWSSEI_getDynamicInfo_RequestStruct)myJobHostWSSEI_getDynamicInfo_RequestStructObj;
        }
        
        try {
            java.lang.String result = 
                ((jwsgrid.jobhost.ws.JobHostWSSEI) getTarget()).getDynamicInfo();
            jwsgrid.jobhost.ws.JobHostWSSEI_getDynamicInfo_ResponseStruct myJobHostWSSEI_getDynamicInfo_ResponseStruct =
                new jwsgrid.jobhost.ws.JobHostWSSEI_getDynamicInfo_ResponseStruct();
            SOAPHeaderBlockInfo headerInfo;
            myJobHostWSSEI_getDynamicInfo_ResponseStruct.setResult(result);
            
            SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_getDynamicInfo_getDynamicInfoResponse_QNAME);
            bodyBlock.setValue(myJobHostWSSEI_getDynamicInfo_ResponseStruct);
            bodyBlock.setSerializer(ns2_myJobHostWSSEI_getDynamicInfo_ResponseStruct_SOAPSerializer);
            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: startJob
     */
    private void invoke_startJob(StreamingHandlerState state) throws Exception {
        
        jwsgrid.jobhost.ws.JobHostWSSEI_startJob_RequestStruct myJobHostWSSEI_startJob_RequestStruct = null;
        Object myJobHostWSSEI_startJob_RequestStructObj =
            state.getRequest().getBody().getValue();
        
        if (myJobHostWSSEI_startJob_RequestStructObj instanceof SOAPDeserializationState) {
            myJobHostWSSEI_startJob_RequestStruct = (jwsgrid.jobhost.ws.JobHostWSSEI_startJob_RequestStruct)((SOAPDeserializationState)myJobHostWSSEI_startJob_RequestStructObj).getInstance();
        } else {
            myJobHostWSSEI_startJob_RequestStruct = (jwsgrid.jobhost.ws.JobHostWSSEI_startJob_RequestStruct)myJobHostWSSEI_startJob_RequestStructObj;
        }
        
        try {
            ((jwsgrid.jobhost.ws.JobHostWSSEI) getTarget()).startJob(myJobHostWSSEI_startJob_RequestStruct.getString_1(), myJobHostWSSEI_startJob_RequestStruct.getString_2());
            jwsgrid.jobhost.ws.JobHostWSSEI_startJob_ResponseStruct myJobHostWSSEI_startJob_ResponseStruct =
                new jwsgrid.jobhost.ws.JobHostWSSEI_startJob_ResponseStruct();
            SOAPHeaderBlockInfo headerInfo;
            
            SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_startJob_startJobResponse_QNAME);
            bodyBlock.setValue(myJobHostWSSEI_startJob_ResponseStruct);
            bodyBlock.setSerializer(ns2_myJobHostWSSEI_startJob_ResponseStruct_SOAPSerializer);
            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: submitJob
     */
    private void invoke_submitJob(StreamingHandlerState state) throws Exception {
        
        jwsgrid.jobhost.ws.JobHostWSSEI_submitJob_RequestStruct myJobHostWSSEI_submitJob_RequestStruct = null;
        Object myJobHostWSSEI_submitJob_RequestStructObj =
            state.getRequest().getBody().getValue();
        
        if (myJobHostWSSEI_submitJob_RequestStructObj instanceof SOAPDeserializationState) {
            myJobHostWSSEI_submitJob_RequestStruct = (jwsgrid.jobhost.ws.JobHostWSSEI_submitJob_RequestStruct)((SOAPDeserializationState)myJobHostWSSEI_submitJob_RequestStructObj).getInstance();
        } else {
            myJobHostWSSEI_submitJob_RequestStruct = (jwsgrid.jobhost.ws.JobHostWSSEI_submitJob_RequestStruct)myJobHostWSSEI_submitJob_RequestStructObj;
        }
        
        try {
            java.lang.String result = 
                ((jwsgrid.jobhost.ws.JobHostWSSEI) getTarget()).submitJob(myJobHostWSSEI_submitJob_RequestStruct.getString_1(), myJobHostWSSEI_submitJob_RequestStruct.getString_2(), myJobHostWSSEI_submitJob_RequestStruct.getInt_3(), myJobHostWSSEI_submitJob_RequestStruct.getDataHandler_4());
            jwsgrid.jobhost.ws.JobHostWSSEI_submitJob_ResponseStruct myJobHostWSSEI_submitJob_ResponseStruct =
                new jwsgrid.jobhost.ws.JobHostWSSEI_submitJob_ResponseStruct();
            SOAPHeaderBlockInfo headerInfo;
            myJobHostWSSEI_submitJob_ResponseStruct.setResult(result);
            
            SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_submitJob_submitJobResponse_QNAME);
            bodyBlock.setValue(myJobHostWSSEI_submitJob_ResponseStruct);
            bodyBlock.setSerializer(ns2_myJobHostWSSEI_submitJob_ResponseStruct_SOAPSerializer);
            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: destroyJob
     */
    private void invoke_destroyJob(StreamingHandlerState state) throws Exception {
        
        jwsgrid.jobhost.ws.JobHostWSSEI_destroyJob_RequestStruct myJobHostWSSEI_destroyJob_RequestStruct = null;
        Object myJobHostWSSEI_destroyJob_RequestStructObj =
            state.getRequest().getBody().getValue();
        
        if (myJobHostWSSEI_destroyJob_RequestStructObj instanceof SOAPDeserializationState) {
            myJobHostWSSEI_destroyJob_RequestStruct = (jwsgrid.jobhost.ws.JobHostWSSEI_destroyJob_RequestStruct)((SOAPDeserializationState)myJobHostWSSEI_destroyJob_RequestStructObj).getInstance();
        } else {
            myJobHostWSSEI_destroyJob_RequestStruct = (jwsgrid.jobhost.ws.JobHostWSSEI_destroyJob_RequestStruct)myJobHostWSSEI_destroyJob_RequestStructObj;
        }
        
        try {
            ((jwsgrid.jobhost.ws.JobHostWSSEI) getTarget()).destroyJob(myJobHostWSSEI_destroyJob_RequestStruct.getString_1(), myJobHostWSSEI_destroyJob_RequestStruct.getString_2());
            jwsgrid.jobhost.ws.JobHostWSSEI_destroyJob_ResponseStruct myJobHostWSSEI_destroyJob_ResponseStruct =
                new jwsgrid.jobhost.ws.JobHostWSSEI_destroyJob_ResponseStruct();
            SOAPHeaderBlockInfo headerInfo;
            
            SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_destroyJob_destroyJobResponse_QNAME);
            bodyBlock.setValue(myJobHostWSSEI_destroyJob_ResponseStruct);
            bodyBlock.setSerializer(ns2_myJobHostWSSEI_destroyJob_ResponseStruct_SOAPSerializer);
            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.jobhost.ws.JobHostWSSEI_ping_RequestStruct myJobHostWSSEI_ping_RequestStruct = null;
        Object myJobHostWSSEI_ping_RequestStructObj =
            state.getRequest().getBody().getValue();
        
        if (myJobHostWSSEI_ping_RequestStructObj instanceof SOAPDeserializationState) {
            myJobHostWSSEI_ping_RequestStruct = (jwsgrid.jobhost.ws.JobHostWSSEI_ping_RequestStruct)((SOAPDeserializationState)myJobHostWSSEI_ping_RequestStructObj).getInstance();
        } else {
            myJobHostWSSEI_ping_RequestStruct = (jwsgrid.jobhost.ws.JobHostWSSEI_ping_RequestStruct)myJobHostWSSEI_ping_RequestStructObj;