jobhostwssei_tie.java

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

            case destroyJob_OPCODE:
                deserialize_destroyJob(bodyReader, deserializationContext, state);
                break;
            case ping_OPCODE:
                deserialize_ping(bodyReader, deserializationContext, state);
                break;
            case getJobOutputFiles_OPCODE:
                deserialize_getJobOutputFiles(bodyReader, deserializationContext, state);
                break;
            case getJobStatus_OPCODE:
                deserialize_getJobStatus(bodyReader, deserializationContext, state);
                break;
            case getJobOutputFile_OPCODE:
                deserialize_getJobOutputFile(bodyReader, deserializationContext, state);
                break;
            case getJobStatus2_OPCODE:
                deserialize_getJobStatus2(bodyReader, deserializationContext, state);
                break;
            default:
                throw new SOAPProtocolViolationException("soap.operation.unrecognized", Integer.toString(opcode));
        }
    }
    
    
    
    /*
     * This method deserializes the body of the stopJob operation.
     */
    private void deserialize_stopJob(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object myJobHostWSSEI_stopJob_RequestStructObj =
            ns2_myJobHostWSSEI_stopJob_RequestStruct_SOAPSerializer.deserialize(ns1_stopJob_stopJob_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_stopJob_stopJob_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_stopJob_RequestStructObj);
        state.getRequest().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the getDynamicInfo operation.
     */
    private void deserialize_getDynamicInfo(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object myJobHostWSSEI_getDynamicInfo_RequestStructObj =
            ns2_myJobHostWSSEI_getDynamicInfo_RequestStruct_SOAPSerializer.deserialize(ns1_getDynamicInfo_getDynamicInfo_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_getDynamicInfo_getDynamicInfo_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_getDynamicInfo_RequestStructObj);
        state.getRequest().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the startJob operation.
     */
    private void deserialize_startJob(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object myJobHostWSSEI_startJob_RequestStructObj =
            ns2_myJobHostWSSEI_startJob_RequestStruct_SOAPSerializer.deserialize(ns1_startJob_startJob_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_startJob_startJob_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_startJob_RequestStructObj);
        state.getRequest().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the submitJob operation.
     */
    private void deserialize_submitJob(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object myJobHostWSSEI_submitJob_RequestStructObj =
            ns2_myJobHostWSSEI_submitJob_RequestStruct_SOAPSerializer.deserialize(ns1_submitJob_submitJob_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_submitJob_submitJob_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_submitJob_RequestStructObj);
        state.getRequest().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the destroyJob operation.
     */
    private void deserialize_destroyJob(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object myJobHostWSSEI_destroyJob_RequestStructObj =
            ns2_myJobHostWSSEI_destroyJob_RequestStruct_SOAPSerializer.deserialize(ns1_destroyJob_destroyJob_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_destroyJob_destroyJob_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_destroyJob_RequestStructObj);
        state.getRequest().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the ping operation.
     */
    private void deserialize_ping(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object myJobHostWSSEI_ping_RequestStructObj =
            ns2_myJobHostWSSEI_ping_RequestStruct_SOAPSerializer.deserialize(ns1_ping_ping_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_ping_ping_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_ping_RequestStructObj);
        state.getRequest().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the getJobOutputFiles operation.
     */
    private void deserialize_getJobOutputFiles(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object myJobHostWSSEI_getJobOutputFiles_RequestStructObj =
            ns2_myJobHostWSSEI_getJobOutputFiles_RequestStruct_SOAPSerializer.deserialize(ns1_getJobOutputFiles_getJobOutputFiles_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_getJobOutputFiles_getJobOutputFiles_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_getJobOutputFiles_RequestStructObj);
        state.getRequest().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the getJobStatus operation.
     */
    private void deserialize_getJobStatus(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object myJobHostWSSEI_getJobStatus_RequestStructObj =
            ns2_myJobHostWSSEI_getJobStatus_RequestStruct_SOAPSerializer.deserialize(ns1_getJobStatus_getJobStatus_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_getJobStatus_getJobStatus_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_getJobStatus_RequestStructObj);
        state.getRequest().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the getJobOutputFile operation.
     */
    private void deserialize_getJobOutputFile(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object myJobHostWSSEI_getJobOutputFile_RequestStructObj =
            ns2_myJobHostWSSEI_getJobOutputFile_RequestStruct_SOAPSerializer.deserialize(ns1_getJobOutputFile_getJobOutputFile_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_getJobOutputFile_getJobOutputFile_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_getJobOutputFile_RequestStructObj);
        state.getRequest().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the getJobStatus2 operation.
     */
    private void deserialize_getJobStatus2(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object myJobHostWSSEI_getJobStatus2_RequestStructObj =
            ns2_myJobHostWSSEI_getJobStatus2_RequestStruct_SOAPSerializer.deserialize(ns1_getJobStatus2_getJobStatus2_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_getJobStatus2_getJobStatus2_QNAME);
        bodyBlock.setValue(myJobHostWSSEI_getJobStatus2_RequestStructObj);
        state.getRequest().setBody(bodyBlock);
    }
    
    
    /*
     * This method must invoke the correct method on the servant based on the opcode.
     */
    protected void processingHook(StreamingHandlerState state) throws Exception {
        switch (state.getRequest().getOperationCode()) {
            case stopJob_OPCODE:
                invoke_stopJob(state);
                break;
            case getDynamicInfo_OPCODE:
                invoke_getDynamicInfo(state);
                break;
            case startJob_OPCODE:
                invoke_startJob(state);
                break;
            case submitJob_OPCODE:
                invoke_submitJob(state);
                break;
            case destroyJob_OPCODE:
                invoke_destroyJob(state);
                break;
            case ping_OPCODE:
                invoke_ping(state);
                break;
            case getJobOutputFiles_OPCODE:
                invoke_getJobOutputFiles(state);
                break;
            case getJobStatus_OPCODE:
                invoke_getJobStatus(state);
                break;
            case getJobOutputFile_OPCODE:
                invoke_getJobOutputFile(state);
                break;
            case getJobStatus2_OPCODE:
                invoke_getJobStatus2(state);
                break;
            default:
                throw new SOAPProtocolViolationException("soap.operation.unrecognized", Integer.toString(state.getRequest().getOperationCode()));
        }
    }
    
    public String getDefaultEnvelopeEncodingStyle() {
        return SOAPNamespaceConstants.ENCODING;
    }
    
    public String getImplicitEnvelopeEncodingStyle() {
        return "";
    }
    
    
    /*
     * This method must determine the opcode of the operation given the QName of the first body element.
     */
    public int getOpcodeForFirstBodyElementName(QName name) {
        if (name == null) {
            return InternalSOAPMessage.NO_OPERATION;
        }
        if (name.equals(ns1_stopJob_stopJob_QNAME)) {
            return stopJob_OPCODE;
        }
        if (name.equals(ns1_getDynamicInfo_getDynamicInfo_QNAME)) {
            return getDynamicInfo_OPCODE;
        }
        if (name.equals(ns1_startJob_startJob_QNAME)) {
            return startJob_OPCODE;
        }
        if (name.equals(ns1_submitJob_submitJob_QNAME)) {
            return submitJob_OPCODE;
        }
        if (name.equals(ns1_destroyJob_destroyJob_QNAME)) {
            return destroyJob_OPCODE;
        }
        if (name.equals(ns1_ping_ping_QNAME)) {
            return ping_OPCODE;
        }
        if (name.equals(ns1_getJobOutputFiles_getJobOutputFiles_QNAME)) {
            return getJobOutputFiles_OPCODE;
        }
        if (name.equals(ns1_getJobStatus_getJobStatus_QNAME)) {