jobhostwssei_stub.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.ws.jobhost;

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.client.SenderException;
import com.sun.xml.rpc.client.*;
import com.sun.xml.rpc.client.http.*;
import javax.xml.rpc.handler.*;
import javax.xml.rpc.JAXRPCException;
import javax.xml.rpc.soap.SOAPFaultException;

public class JobHostWSSEI_Stub
    extends com.sun.xml.rpc.client.StubBase
    implements jwsgrid.ws.jobhost.JobHostWSSEI {
    
    
    
    /*
     *  public constructor
     */
    public JobHostWSSEI_Stub(HandlerChain handlerChain) {
        super(handlerChain);
        _setProperty(ENDPOINT_ADDRESS_PROPERTY, "REPLACE_WITH_ACTUAL_URL");
    }
    
    
    /*
     *  implementation of stopJob
     */
    public void stopJob(java.lang.String string_1, java.lang.String string_2)
        throws java.rmi.RemoteException {
        
        try {
            
            StreamingSenderState _state = _start(_handlerChain);
            
            InternalSOAPMessage _request = _state.getRequest();
            _request.setOperationCode(stopJob_OPCODE);
            jwsgrid.ws.jobhost.JobHostWSSEI_stopJob_RequestStruct _myJobHostWSSEI_stopJob_RequestStruct =
                new jwsgrid.ws.jobhost.JobHostWSSEI_stopJob_RequestStruct();
            
            _myJobHostWSSEI_stopJob_RequestStruct.setString_1(string_1);
            _myJobHostWSSEI_stopJob_RequestStruct.setString_2(string_2);
            
            SOAPBlockInfo _bodyBlock = new SOAPBlockInfo(ns1_stopJob_stopJob_QNAME);
            _bodyBlock.setValue(_myJobHostWSSEI_stopJob_RequestStruct);
            _bodyBlock.setSerializer(ns1_myJobHostWSSEI_stopJob_RequestStruct_SOAPSerializer);
            _request.setBody(_bodyBlock);
            
            _state.getMessageContext().setProperty(HttpClientTransport.HTTP_SOAPACTION_PROPERTY, "");
            
            _send((String) _getProperty(ENDPOINT_ADDRESS_PROPERTY), _state);
            
            jwsgrid.ws.jobhost.JobHostWSSEI_stopJob_ResponseStruct _myJobHostWSSEI_stopJob_ResponseStruct = null;
            Object _responseObj = _state.getResponse().getBody().getValue();
            if (_responseObj instanceof SOAPDeserializationState) {
                _myJobHostWSSEI_stopJob_ResponseStruct =
                    (jwsgrid.ws.jobhost.JobHostWSSEI_stopJob_ResponseStruct)((SOAPDeserializationState)_responseObj).getInstance();
            } else {
                _myJobHostWSSEI_stopJob_ResponseStruct =
                    (jwsgrid.ws.jobhost.JobHostWSSEI_stopJob_ResponseStruct)_responseObj;
            }
            
        } catch (RemoteException e) {
            // let this one through unchanged
            throw e;
        } catch (JAXRPCException e) {
            throw new RemoteException(e.getMessage(), e);
        } catch (Exception e) {
            if (e instanceof RuntimeException) {
                throw (RuntimeException)e;
            } else {
                throw new RemoteException(e.getMessage(), e);
            }
        }
    }
    
    /*
     *  implementation of getJobStatus2
     */
    public java.lang.String getJobStatus2(java.lang.String string_1, java.lang.String string_2)
        throws java.rmi.RemoteException {
        
        try {
            
            StreamingSenderState _state = _start(_handlerChain);
            
            InternalSOAPMessage _request = _state.getRequest();
            _request.setOperationCode(getJobStatus2_OPCODE);
            jwsgrid.ws.jobhost.JobHostWSSEI_getJobStatus2_RequestStruct _myJobHostWSSEI_getJobStatus2_RequestStruct =
                new jwsgrid.ws.jobhost.JobHostWSSEI_getJobStatus2_RequestStruct();
            
            _myJobHostWSSEI_getJobStatus2_RequestStruct.setString_1(string_1);
            _myJobHostWSSEI_getJobStatus2_RequestStruct.setString_2(string_2);
            
            SOAPBlockInfo _bodyBlock = new SOAPBlockInfo(ns1_getJobStatus2_getJobStatus2_QNAME);
            _bodyBlock.setValue(_myJobHostWSSEI_getJobStatus2_RequestStruct);
            _bodyBlock.setSerializer(ns1_myJobHostWSSEI_getJobStatus2_RequestStruct_SOAPSerializer);
            _request.setBody(_bodyBlock);
            
            _state.getMessageContext().setProperty(HttpClientTransport.HTTP_SOAPACTION_PROPERTY, "");
            
            _send((String) _getProperty(ENDPOINT_ADDRESS_PROPERTY), _state);
            
            jwsgrid.ws.jobhost.JobHostWSSEI_getJobStatus2_ResponseStruct _myJobHostWSSEI_getJobStatus2_ResponseStruct = null;
            Object _responseObj = _state.getResponse().getBody().getValue();
            if (_responseObj instanceof SOAPDeserializationState) {
                _myJobHostWSSEI_getJobStatus2_ResponseStruct =
                    (jwsgrid.ws.jobhost.JobHostWSSEI_getJobStatus2_ResponseStruct)((SOAPDeserializationState)_responseObj).getInstance();
            } else {
                _myJobHostWSSEI_getJobStatus2_ResponseStruct =
                    (jwsgrid.ws.jobhost.JobHostWSSEI_getJobStatus2_ResponseStruct)_responseObj;
            }
            
            return _myJobHostWSSEI_getJobStatus2_ResponseStruct.getResult();
        } catch (RemoteException e) {
            // let this one through unchanged
            throw e;
        } catch (JAXRPCException e) {
            throw new RemoteException(e.getMessage(), e);
        } catch (Exception e) {
            if (e instanceof RuntimeException) {
                throw (RuntimeException)e;
            } else {
                throw new RemoteException(e.getMessage(), e);
            }
        }
    }
    
    /*
     *  implementation of destroyJob
     */
    public void destroyJob(java.lang.String string_1, java.lang.String string_2)
        throws java.rmi.RemoteException {
        
        try {
            
            StreamingSenderState _state = _start(_handlerChain);
            
            InternalSOAPMessage _request = _state.getRequest();
            _request.setOperationCode(destroyJob_OPCODE);
            jwsgrid.ws.jobhost.JobHostWSSEI_destroyJob_RequestStruct _myJobHostWSSEI_destroyJob_RequestStruct =
                new jwsgrid.ws.jobhost.JobHostWSSEI_destroyJob_RequestStruct();
            
            _myJobHostWSSEI_destroyJob_RequestStruct.setString_1(string_1);
            _myJobHostWSSEI_destroyJob_RequestStruct.setString_2(string_2);
            
            SOAPBlockInfo _bodyBlock = new SOAPBlockInfo(ns1_destroyJob_destroyJob_QNAME);
            _bodyBlock.setValue(_myJobHostWSSEI_destroyJob_RequestStruct);
            _bodyBlock.setSerializer(ns1_myJobHostWSSEI_destroyJob_RequestStruct_SOAPSerializer);
            _request.setBody(_bodyBlock);
            
            _state.getMessageContext().setProperty(HttpClientTransport.HTTP_SOAPACTION_PROPERTY, "");
            
            _send((String) _getProperty(ENDPOINT_ADDRESS_PROPERTY), _state);
            
            jwsgrid.ws.jobhost.JobHostWSSEI_destroyJob_ResponseStruct _myJobHostWSSEI_destroyJob_ResponseStruct = null;
            Object _responseObj = _state.getResponse().getBody().getValue();
            if (_responseObj instanceof SOAPDeserializationState) {
                _myJobHostWSSEI_destroyJob_ResponseStruct =
                    (jwsgrid.ws.jobhost.JobHostWSSEI_destroyJob_ResponseStruct)((SOAPDeserializationState)_responseObj).getInstance();
            } else {
                _myJobHostWSSEI_destroyJob_ResponseStruct =
                    (jwsgrid.ws.jobhost.JobHostWSSEI_destroyJob_ResponseStruct)_responseObj;
            }
            
        } catch (RemoteException e) {
            // let this one through unchanged
            throw e;
        } catch (JAXRPCException e) {
            throw new RemoteException(e.getMessage(), e);
        } catch (Exception e) {
            if (e instanceof RuntimeException) {
                throw (RuntimeException)e;
            } else {
                throw new RemoteException(e.getMessage(), e);
            }
        }
    }
    
    /*
     *  implementation of startJob
     */
    public void startJob(java.lang.String string_1, java.lang.String string_2)
        throws java.rmi.RemoteException {
        
        try {
            
            StreamingSenderState _state = _start(_handlerChain);
            
            InternalSOAPMessage _request = _state.getRequest();
            _request.setOperationCode(startJob_OPCODE);
            jwsgrid.ws.jobhost.JobHostWSSEI_startJob_RequestStruct _myJobHostWSSEI_startJob_RequestStruct =
                new jwsgrid.ws.jobhost.JobHostWSSEI_startJob_RequestStruct();
            
            _myJobHostWSSEI_startJob_RequestStruct.setString_1(string_1);
            _myJobHostWSSEI_startJob_RequestStruct.setString_2(string_2);
            
            SOAPBlockInfo _bodyBlock = new SOAPBlockInfo(ns1_startJob_startJob_QNAME);
            _bodyBlock.setValue(_myJobHostWSSEI_startJob_RequestStruct);