jobhostwssei_stub.java

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

                _myJobHostWSSEI_getJobStatus_ResponseStruct =
                    (jwsgrid.ws.jobhost.JobHostWSSEI_getJobStatus_ResponseStruct)((SOAPDeserializationState)_responseObj).getInstance();
            } else {
                _myJobHostWSSEI_getJobStatus_ResponseStruct =
                    (jwsgrid.ws.jobhost.JobHostWSSEI_getJobStatus_ResponseStruct)_responseObj;
            }
            
            return _myJobHostWSSEI_getJobStatus_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 getDynamicInfo
     */
    public java.lang.String getDynamicInfo()
        throws java.rmi.RemoteException {
        
        try {
            
            StreamingSenderState _state = _start(_handlerChain);
            
            InternalSOAPMessage _request = _state.getRequest();
            _request.setOperationCode(getDynamicInfo_OPCODE);
            jwsgrid.ws.jobhost.JobHostWSSEI_getDynamicInfo_RequestStruct _myJobHostWSSEI_getDynamicInfo_RequestStruct =
                new jwsgrid.ws.jobhost.JobHostWSSEI_getDynamicInfo_RequestStruct();
            
            
            SOAPBlockInfo _bodyBlock = new SOAPBlockInfo(ns1_getDynamicInfo_getDynamicInfo_QNAME);
            _bodyBlock.setValue(_myJobHostWSSEI_getDynamicInfo_RequestStruct);
            _bodyBlock.setSerializer(ns1_myJobHostWSSEI_getDynamicInfo_RequestStruct_SOAPSerializer);
            _request.setBody(_bodyBlock);
            
            _state.getMessageContext().setProperty(HttpClientTransport.HTTP_SOAPACTION_PROPERTY, "");
            
            _send((String) _getProperty(ENDPOINT_ADDRESS_PROPERTY), _state);
            
            jwsgrid.ws.jobhost.JobHostWSSEI_getDynamicInfo_ResponseStruct _myJobHostWSSEI_getDynamicInfo_ResponseStruct = null;
            Object _responseObj = _state.getResponse().getBody().getValue();
            if (_responseObj instanceof SOAPDeserializationState) {
                _myJobHostWSSEI_getDynamicInfo_ResponseStruct =
                    (jwsgrid.ws.jobhost.JobHostWSSEI_getDynamicInfo_ResponseStruct)((SOAPDeserializationState)_responseObj).getInstance();
            } else {
                _myJobHostWSSEI_getDynamicInfo_ResponseStruct =
                    (jwsgrid.ws.jobhost.JobHostWSSEI_getDynamicInfo_ResponseStruct)_responseObj;
            }
            
            return _myJobHostWSSEI_getDynamicInfo_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 ping
     */
    public long ping()
        throws java.rmi.RemoteException {
        
        try {
            
            StreamingSenderState _state = _start(_handlerChain);
            
            InternalSOAPMessage _request = _state.getRequest();
            _request.setOperationCode(ping_OPCODE);
            jwsgrid.ws.jobhost.JobHostWSSEI_ping_RequestStruct _myJobHostWSSEI_ping_RequestStruct =
                new jwsgrid.ws.jobhost.JobHostWSSEI_ping_RequestStruct();
            
            
            SOAPBlockInfo _bodyBlock = new SOAPBlockInfo(ns1_ping_ping_QNAME);
            _bodyBlock.setValue(_myJobHostWSSEI_ping_RequestStruct);
            _bodyBlock.setSerializer(ns1_myJobHostWSSEI_ping_RequestStruct_SOAPSerializer);
            _request.setBody(_bodyBlock);
            
            _state.getMessageContext().setProperty(HttpClientTransport.HTTP_SOAPACTION_PROPERTY, "");
            
            _send((String) _getProperty(ENDPOINT_ADDRESS_PROPERTY), _state);
            
            jwsgrid.ws.jobhost.JobHostWSSEI_ping_ResponseStruct _myJobHostWSSEI_ping_ResponseStruct = null;
            Object _responseObj = _state.getResponse().getBody().getValue();
            if (_responseObj instanceof SOAPDeserializationState) {
                _myJobHostWSSEI_ping_ResponseStruct =
                    (jwsgrid.ws.jobhost.JobHostWSSEI_ping_ResponseStruct)((SOAPDeserializationState)_responseObj).getInstance();
            } else {
                _myJobHostWSSEI_ping_ResponseStruct =
                    (jwsgrid.ws.jobhost.JobHostWSSEI_ping_ResponseStruct)_responseObj;
            }
            
            return _myJobHostWSSEI_ping_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);
            }
        }
    }
    
    
    /*
     *  this method deserializes the request/response structure in the body
     */
    protected void _readFirstBodyElement(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingSenderState  state) throws Exception {
        int opcode = state.getRequest().getOperationCode();
        switch (opcode) {
            case stopJob_OPCODE:
                _deserialize_stopJob(bodyReader, deserializationContext, state);
                break;
            case getJobStatus2_OPCODE:
                _deserialize_getJobStatus2(bodyReader, deserializationContext, state);
                break;
            case destroyJob_OPCODE:
                _deserialize_destroyJob(bodyReader, deserializationContext, state);
                break;
            case startJob_OPCODE:
                _deserialize_startJob(bodyReader, deserializationContext, state);
                break;
            case getJobOutputFiles_OPCODE:
                _deserialize_getJobOutputFiles(bodyReader, deserializationContext, state);
                break;
            case getJobOutputFile_OPCODE:
                _deserialize_getJobOutputFile(bodyReader, deserializationContext, state);
                break;
            case submitJob_OPCODE:
                _deserialize_submitJob(bodyReader, deserializationContext, state);
                break;
            case getJobStatus_OPCODE:
                _deserialize_getJobStatus(bodyReader, deserializationContext, state);
                break;
            case getDynamicInfo_OPCODE:
                _deserialize_getDynamicInfo(bodyReader, deserializationContext, state);
                break;
            case ping_OPCODE:
                _deserialize_ping(bodyReader, deserializationContext, state);
                break;
            default:
                throw new SenderException("sender.response.unrecognizedOperation", Integer.toString(opcode));
        }
    }
    
    
    
    /*
     * This method deserializes the body of the stopJob operation.
     */
    private void _deserialize_stopJob(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingSenderState state) throws Exception {
        Object myJobHostWSSEI_stopJob_ResponseStructObj =
            ns1_myJobHostWSSEI_stopJob_ResponseStruct_SOAPSerializer.deserialize(ns1_stopJob_stopJobResponse_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_stopJob_stopJobResponse_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_stopJob_ResponseStructObj);
        state.getResponse().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the getJobStatus2 operation.
     */
    private void _deserialize_getJobStatus2(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingSenderState state) throws Exception {
        Object myJobHostWSSEI_getJobStatus2_ResponseStructObj =
            ns1_myJobHostWSSEI_getJobStatus2_ResponseStruct_SOAPSerializer.deserialize(ns1_getJobStatus2_getJobStatus2Response_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_getJobStatus2_getJobStatus2Response_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_getJobStatus2_ResponseStructObj);
        state.getResponse().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the destroyJob operation.
     */
    private void _deserialize_destroyJob(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingSenderState state) throws Exception {
        Object myJobHostWSSEI_destroyJob_ResponseStructObj =
            ns1_myJobHostWSSEI_destroyJob_ResponseStruct_SOAPSerializer.deserialize(ns1_destroyJob_destroyJobResponse_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_destroyJob_destroyJobResponse_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_destroyJob_ResponseStructObj);
        state.getResponse().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the startJob operation.
     */
    private void _deserialize_startJob(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingSenderState state) throws Exception {
        Object myJobHostWSSEI_startJob_ResponseStructObj =
            ns1_myJobHostWSSEI_startJob_ResponseStruct_SOAPSerializer.deserialize(ns1_startJob_startJobResponse_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_startJob_startJobResponse_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_startJob_ResponseStructObj);
        state.getResponse().setBody(bodyBlock);
    }
    
    /*