schedulerwssei_stub.java

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

        try {
            
            StreamingSenderState _state = _start(_handlerChain);
            
            InternalSOAPMessage _request = _state.getRequest();
            _request.setOperationCode(ping_OPCODE);
            jwsgrid.ws.scheduler.SchedulerWSSEI_ping_RequestStruct _mySchedulerWSSEI_ping_RequestStruct =
                new jwsgrid.ws.scheduler.SchedulerWSSEI_ping_RequestStruct();
            
            
            SOAPBlockInfo _bodyBlock = new SOAPBlockInfo(ns1_ping_ping_QNAME);
            _bodyBlock.setValue(_mySchedulerWSSEI_ping_RequestStruct);
            _bodyBlock.setSerializer(ns1_mySchedulerWSSEI_ping_RequestStruct_SOAPSerializer);
            _request.setBody(_bodyBlock);
            
            _state.getMessageContext().setProperty(HttpClientTransport.HTTP_SOAPACTION_PROPERTY, "");
            
            _send((String) _getProperty(ENDPOINT_ADDRESS_PROPERTY), _state);
            
            jwsgrid.ws.scheduler.SchedulerWSSEI_ping_ResponseStruct _mySchedulerWSSEI_ping_ResponseStruct = null;
            Object _responseObj = _state.getResponse().getBody().getValue();
            if (_responseObj instanceof SOAPDeserializationState) {
                _mySchedulerWSSEI_ping_ResponseStruct =
                    (jwsgrid.ws.scheduler.SchedulerWSSEI_ping_ResponseStruct)((SOAPDeserializationState)_responseObj).getInstance();
            } else {
                _mySchedulerWSSEI_ping_ResponseStruct =
                    (jwsgrid.ws.scheduler.SchedulerWSSEI_ping_ResponseStruct)_responseObj;
            }
            
            return _mySchedulerWSSEI_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 queryBundle_OPCODE:
                _deserialize_queryBundle(bodyReader, deserializationContext, state);
                break;
            case scheduleBundle_OPCODE:
                _deserialize_scheduleBundle(bodyReader, deserializationContext, state);
                break;
            case queryBundle2_OPCODE:
                _deserialize_queryBundle2(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 queryBundle operation.
     */
    private void _deserialize_queryBundle(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingSenderState state) throws Exception {
        Object mySchedulerWSSEI_queryBundle_ResponseStructObj =
            ns1_mySchedulerWSSEI_queryBundle_ResponseStruct_SOAPSerializer.deserialize(ns1_queryBundle_queryBundleResponse_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_queryBundle_queryBundleResponse_QNAME);
        bodyBlock.setValue(mySchedulerWSSEI_queryBundle_ResponseStructObj);
        state.getResponse().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the scheduleBundle operation.
     */
    private void _deserialize_scheduleBundle(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingSenderState state) throws Exception {
        Object mySchedulerWSSEI_scheduleBundle_ResponseStructObj =
            ns1_mySchedulerWSSEI_scheduleBundle_ResponseStruct_SOAPSerializer.deserialize(ns1_scheduleBundle_scheduleBundleResponse_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_scheduleBundle_scheduleBundleResponse_QNAME);
        bodyBlock.setValue(mySchedulerWSSEI_scheduleBundle_ResponseStructObj);
        state.getResponse().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the queryBundle2 operation.
     */
    private void _deserialize_queryBundle2(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingSenderState state) throws Exception {
        Object mySchedulerWSSEI_queryBundle2_ResponseStructObj =
            ns1_mySchedulerWSSEI_queryBundle2_ResponseStruct_SOAPSerializer.deserialize(ns1_queryBundle2_queryBundle2Response_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_queryBundle2_queryBundle2Response_QNAME);
        bodyBlock.setValue(mySchedulerWSSEI_queryBundle2_ResponseStructObj);
        state.getResponse().setBody(bodyBlock);
    }
    
    /*
     * This method deserializes the body of the ping operation.
     */
    private void _deserialize_ping(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingSenderState state) throws Exception {
        Object mySchedulerWSSEI_ping_ResponseStructObj =
            ns1_mySchedulerWSSEI_ping_ResponseStruct_SOAPSerializer.deserialize(ns1_ping_pingResponse_QNAME,
                bodyReader, deserializationContext);
        
        SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_ping_pingResponse_QNAME);
        bodyBlock.setValue(mySchedulerWSSEI_ping_ResponseStructObj);
        state.getResponse().setBody(bodyBlock);
    }
    
    
    
    public String _getDefaultEnvelopeEncodingStyle() {
        return SOAPNamespaceConstants.ENCODING;
    }
    
    public String _getImplicitEnvelopeEncodingStyle() {
        return "";
    }
    
    public String _getEncodingStyle() {
        return SOAPNamespaceConstants.ENCODING;
    }
    
    public void _setEncodingStyle(String encodingStyle) {
        throw new UnsupportedOperationException("cannot set encoding style");
    }
    
    
    
    
    
    /*
     * 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;
    }
    
    public void _initialize(InternalTypeMappingRegistry registry) throws Exception {
        super._initialize(registry);
        ns1_mySchedulerWSSEI_queryBundle2_RequestStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_queryBundle2_RequestStruct.class, ns1_queryBundle2_TYPE_QNAME);
        ns1_mySchedulerWSSEI_queryBundle_RequestStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_queryBundle_RequestStruct.class, ns1_queryBundle_TYPE_QNAME);
        ns1_mySchedulerWSSEI_queryBundle_ResponseStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_queryBundle_ResponseStruct.class, ns1_queryBundleResponse_TYPE_QNAME);
        ns1_mySchedulerWSSEI_queryBundle2_ResponseStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_queryBundle2_ResponseStruct.class, ns1_queryBundle2Response_TYPE_QNAME);
        ns1_mySchedulerWSSEI_scheduleBundle_ResponseStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_scheduleBundle_ResponseStruct.class, ns1_scheduleBundleResponse_TYPE_QNAME);
        ns1_mySchedulerWSSEI_scheduleBundle_RequestStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_scheduleBundle_RequestStruct.class, ns1_scheduleBundle_TYPE_QNAME);
        ns1_mySchedulerWSSEI_ping_ResponseStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_ping_ResponseStruct.class, ns1_pingResponse_TYPE_QNAME);
        ns1_mySchedulerWSSEI_ping_RequestStruct_SOAPSerializer = (CombinedSerializer)registry.getSerializer(SOAPConstants.NS_SOAP_ENCODING, jwsgrid.ws.scheduler.SchedulerWSSEI_ping_RequestStruct.class, ns1_ping_TYPE_QNAME);
    }
    
    private static final QName _portName = new QName("urn:SchedulerWS/wsdl", "SchedulerWSSEIPort");
    private static final int queryBundle_OPCODE = 0;
    private static final int scheduleBundle_OPCODE = 1;
    private static final int queryBundle2_OPCODE = 2;
    private static final int ping_OPCODE = 3;
    private static final QName ns1_queryBundle_queryBundle_QNAME = new QName("urn:SchedulerWS/wsdl", "queryBundle");
    private static final QName ns1_queryBundle_TYPE_QNAME = new QName("urn:SchedulerWS/wsdl", "queryBundle");
    private CombinedSerializer ns1_mySchedulerWSSEI_queryBundle_RequestStruct_SOAPSerializer;
    private static final QName ns1_queryBundle_queryBundleResponse_QNAME = new QName("urn:SchedulerWS/wsdl", "queryBundleResponse");
    private static final QName ns1_queryBundleResponse_TYPE_QNAME = new QName("urn:SchedulerWS/wsdl", "queryBundleResponse");
    private CombinedSerializer ns1_mySchedulerWSSEI_queryBundle_ResponseStruct_SOAPSerializer;
    private static final QName ns1_scheduleBundle_scheduleBundle_QNAME = new QName("urn:SchedulerWS/wsdl", "scheduleBundle");
    private static final QName ns1_scheduleBundle_TYPE_QNAME = new QName("urn:SchedulerWS/wsdl", "scheduleBundle");
    private CombinedSerializer ns1_mySchedulerWSSEI_scheduleBundle_RequestStruct_SOAPSerializer;
    private static final QName ns1_scheduleBundle_scheduleBundleResponse_QNAME = new QName("urn:SchedulerWS/wsdl", "scheduleBundleResponse");
    private static final QName ns1_scheduleBundleResponse_TYPE_QNAME = new QName("urn:SchedulerWS/wsdl", "scheduleBundleResponse");
    private CombinedSerializer ns1_mySchedulerWSSEI_scheduleBundle_ResponseStruct_SOAPSerializer;
    private static final QName ns1_queryBundle2_queryBundle2_QNAME = new QName("urn:SchedulerWS/wsdl", "queryBundle2");
    private static final QName ns1_queryBundle2_TYPE_QNAME = new QName("urn:SchedulerWS/wsdl", "queryBundle2");
    private CombinedSerializer ns1_mySchedulerWSSEI_queryBundle2_RequestStruct_SOAPSerializer;
    private static final QName ns1_queryBundle2_queryBundle2Response_QNAME = new QName("urn:SchedulerWS/wsdl", "queryBundle2Response");
    private static final QName ns1_queryBundle2Response_TYPE_QNAME = new QName("urn:SchedulerWS/wsdl", "queryBundle2Response");
    private CombinedSerializer ns1_mySchedulerWSSEI_queryBundle2_ResponseStruct_SOAPSerializer;
    private static final QName ns1_ping_ping_QNAME = new QName("urn:SchedulerWS/wsdl", "ping");
    private static final QName ns1_ping_TYPE_QNAME = new QName("urn:SchedulerWS/wsdl", "ping");
    private CombinedSerializer ns1_mySchedulerWSSEI_ping_RequestStruct_SOAPSerializer;
    private static final QName ns1_ping_pingResponse_QNAME = new QName("urn:SchedulerWS/wsdl", "pingResponse");
    private static final QName ns1_pingResponse_TYPE_QNAME = new QName("urn:SchedulerWS/wsdl", "pingResponse");
    private CombinedSerializer ns1_mySchedulerWSSEI_ping_ResponseStruct_SOAPSerializer;
    private static final String[] myNamespace_declarations =
                                        new String[] {
                                            "ns0", "urn:SchedulerWS/wsdl",
                                            "ns1", "http://java.sun.com/jax-rpc-ri/internal"
                                        };
    
    private static final QName[] understoodHeaderNames = new QName[] {  };
}