schedulerwssei_tie.java

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

    
    
    /*
     * This method deserializes the body of the ping operation.
     */
    private void deserialize_ping(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object mySchedulerWSSEI_ping_RequestStructObj =
            ns2_mySchedulerWSSEI_ping_RequestStruct_SOAPSerializer.deserialize(ns1_ping_ping_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_ping_ping_QNAME);
        bodyBlock.setValue(mySchedulerWSSEI_ping_RequestStructObj);
        state.getRequest().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the queryBundle2 operation.
     */
    private void deserialize_queryBundle2(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object mySchedulerWSSEI_queryBundle2_RequestStructObj =
            ns2_mySchedulerWSSEI_queryBundle2_RequestStruct_SOAPSerializer.deserialize(ns1_queryBundle2_queryBundle2_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_queryBundle2_queryBundle2_QNAME);
        bodyBlock.setValue(mySchedulerWSSEI_queryBundle2_RequestStructObj);
        state.getRequest().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the queryBundle operation.
     */
    private void deserialize_queryBundle(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object mySchedulerWSSEI_queryBundle_RequestStructObj =
            ns2_mySchedulerWSSEI_queryBundle_RequestStruct_SOAPSerializer.deserialize(ns1_queryBundle_queryBundle_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_queryBundle_queryBundle_QNAME);
        bodyBlock.setValue(mySchedulerWSSEI_queryBundle_RequestStructObj);
        state.getRequest().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the scheduleBundle operation.
     */
    private void deserialize_scheduleBundle(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingHandlerState state) throws Exception {
        Object mySchedulerWSSEI_scheduleBundle_RequestStructObj =
            ns2_mySchedulerWSSEI_scheduleBundle_RequestStruct_SOAPSerializer.deserialize(ns1_scheduleBundle_scheduleBundle_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_scheduleBundle_scheduleBundle_QNAME);
        bodyBlock.setValue(mySchedulerWSSEI_scheduleBundle_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 ping_OPCODE:
                invoke_ping(state);
                break;
            case queryBundle2_OPCODE:
                invoke_queryBundle2(state);
                break;
            case queryBundle_OPCODE:
                invoke_queryBundle(state);
                break;
            case scheduleBundle_OPCODE:
                invoke_scheduleBundle(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_ping_ping_QNAME)) {
            return ping_OPCODE;
        }
        if (name.equals(ns1_queryBundle2_queryBundle2_QNAME)) {
            return queryBundle2_OPCODE;
        }
        if (name.equals(ns1_queryBundle_queryBundle_QNAME)) {
            return queryBundle_OPCODE;
        }
        if (name.equals(ns1_scheduleBundle_scheduleBundle_QNAME)) {
            return scheduleBundle_OPCODE;
        }
        return super.getOpcodeForFirstBodyElementName(name);
    }
    
    
    private Method internalGetMethodForOpcode(int opcode) throws ClassNotFoundException, NoSuchMethodException {
        
        Method theMethod = null;
        
        switch(opcode) {
            case ping_OPCODE:
                {
                    Class[] carray = {  };
                    theMethod = (jwsgrid.ws.scheduler.SchedulerWSSEI.class).getMethod("ping", carray);
                }
                break;
            
            case queryBundle2_OPCODE:
                {
                    Class[] carray = { java.lang.String.class,java.lang.String.class };
                    theMethod = (jwsgrid.ws.scheduler.SchedulerWSSEI.class).getMethod("queryBundle", carray);
                }
                break;
            
            case queryBundle_OPCODE:
                {
                    Class[] carray = { java.lang.String.class };
                    theMethod = (jwsgrid.ws.scheduler.SchedulerWSSEI.class).getMethod("queryBundle", carray);
                }
                break;
            
            case scheduleBundle_OPCODE:
                {
                    Class[] carray = { java.lang.String.class,java.lang.String.class,java.lang.String.class,javax.activation.DataHandler.class };
                    theMethod = (jwsgrid.ws.scheduler.SchedulerWSSEI.class).getMethod("scheduleBundle", carray);
                }
                break;
            
            default:
        }
        return theMethod;
    }
    
    private Method[] methodMap = new Method[4];
    
    /*
     * This method returns the Method Obj for a specified opcode.
     */
    public Method getMethodForOpcode(int opcode) throws ClassNotFoundException, NoSuchMethodException {
         
        if (opcode <= InternalSOAPMessage.NO_OPERATION ) {
            return null;
        }
         
        if (opcode >= 4 ) {
            return null;
        }
         
        if (methodMap[opcode] == null)  {
            methodMap[opcode] = internalGetMethodForOpcode(opcode);
        }
         
        return methodMap[opcode];
    }
    
    /*
     * This method returns an array containing (prefix, nsURI) pairs.
     */
    protected String[] getNamespaceDeclarations() {
        return myNamespace_declarations;
    }
    
    /*
     * This method returns an array containing the names of the headers we understand.
     */
    public QName[] getUnderstoodHeaders() {
        return understoodHeaderNames;
    }
    
    private void initialize(InternalTypeMappingRegistry registry) throws Exception {
        ns2_mySchedulerWSSEI_queryBundle2_RequestStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_queryBundle2_RequestStruct.class, ns2_queryBundle2_TYPE_QNAME);
        ns2_mySchedulerWSSEI_queryBundle_ResponseStruct1_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_queryBundle_ResponseStruct1.class, ns2_queryBundle2Response_TYPE_QNAME);
        ns2_mySchedulerWSSEI_queryBundle_RequestStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_queryBundle_RequestStruct.class, ns2_queryBundle_TYPE_QNAME);
        ns2_mySchedulerWSSEI_queryBundle_ResponseStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_queryBundle_ResponseStruct.class, ns2_queryBundleResponse_TYPE_QNAME);
        ns2_mySchedulerWSSEI_scheduleBundle_ResponseStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_scheduleBundle_ResponseStruct.class, ns2_scheduleBundleResponse_TYPE_QNAME);
        ns2_mySchedulerWSSEI_scheduleBundle_RequestStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_scheduleBundle_RequestStruct.class, ns2_scheduleBundle_TYPE_QNAME);
        ns2_mySchedulerWSSEI_ping_ResponseStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_ping_ResponseStruct.class, ns2_pingResponse_TYPE_QNAME);
        ns2_mySchedulerWSSEI_ping_RequestStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_ping_RequestStruct.class, ns2_ping_TYPE_QNAME);
    }
    
    private static final QName portName = new QName("urn:SchedulerWS/wsdl", "SchedulerWSSEI");
    private static final int ping_OPCODE = 0;
    private static final int queryBundle2_OPCODE = 1;
    private static final int queryBundle_OPCODE = 2;
    private static final int scheduleBundle_OPCODE = 3;
    private static final QName ns1_ping_ping_QNAME = new QName("urn:SchedulerWS/wsdl", "ping");
    private static final QName ns2_ping_TYPE_QNAME = new QName("urn:SchedulerWS/types", "ping");
    private CombinedSerializer ns2_mySchedulerWSSEI_ping_RequestStruct_SOAPSerializer;
    private static final QName ns1_ping_pingResponse_QNAME = new QName("urn:SchedulerWS/wsdl", "pingResponse");
    private static final QName ns2_pingResponse_TYPE_QNAME = new QName("urn:SchedulerWS/types", "pingResponse");
    private CombinedSerializer ns2_mySchedulerWSSEI_ping_ResponseStruct_SOAPSerializer;
    private static final QName ns1_queryBundle2_queryBundle2_QNAME = new QName("urn:SchedulerWS/wsdl", "queryBundle2");
    private static final QName ns2_queryBundle2_TYPE_QNAME = new QName("urn:SchedulerWS/types", "queryBundle2");
    private CombinedSerializer ns2_mySchedulerWSSEI_queryBundle2_RequestStruct_SOAPSerializer;
    private static final QName ns1_queryBundle2_queryBundle2Response_QNAME = new QName("urn:SchedulerWS/wsdl", "queryBundle2Response");
    private static final QName ns2_queryBundle2Response_TYPE_QNAME = new QName("urn:SchedulerWS/types", "queryBundle2Response");
    private CombinedSerializer ns2_mySchedulerWSSEI_queryBundle_ResponseStruct1_SOAPSerializer;
    private static final QName ns1_queryBundle_queryBundle_QNAME = new QName("urn:SchedulerWS/wsdl", "queryBundle");
    private static final QName ns2_queryBundle_TYPE_QNAME = new QName("urn:SchedulerWS/types", "queryBundle");
    private CombinedSerializer ns2_mySchedulerWSSEI_queryBundle_RequestStruct_SOAPSerializer;
    private static final QName ns1_queryBundle_queryBundleResponse_QNAME = new QName("urn:SchedulerWS/wsdl", "queryBundleResponse");
    private static final QName ns2_queryBundleResponse_TYPE_QNAME = new QName("urn:SchedulerWS/types", "queryBundleResponse");
    private CombinedSerializer ns2_mySchedulerWSSEI_queryBundle_ResponseStruct_SOAPSerializer;
    private static final QName ns1_scheduleBundle_scheduleBundle_QNAME = new QName("urn:SchedulerWS/wsdl", "scheduleBundle");
    private static final QName ns2_scheduleBundle_TYPE_QNAME = new QName("urn:SchedulerWS/types", "scheduleBundle");
    private CombinedSerializer ns2_mySchedulerWSSEI_scheduleBundle_RequestStruct_SOAPSerializer;
    private static final QName ns1_scheduleBundle_scheduleBundleResponse_QNAME = new QName("urn:SchedulerWS/wsdl", "scheduleBundleResponse");
    private static final QName ns2_scheduleBundleResponse_TYPE_QNAME = new QName("urn:SchedulerWS/types", "scheduleBundleResponse");
    private CombinedSerializer ns2_mySchedulerWSSEI_scheduleBundle_ResponseStruct_SOAPSerializer;
    private static final String[] myNamespace_declarations =
                                        new String[] {
                                            "ns0", "urn:SchedulerWS/types",
                                            "ns1", "http://java.sun.com/jax-rpc-ri/internal"
                                        };
    
    private static final QName[] understoodHeaderNames = new QName[] {  };
}