resourcemanagerwssei_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.resourcemanager;

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 ResourceManagerWSSEI_Stub
    extends com.sun.xml.rpc.client.StubBase
    implements jwsgrid.ws.resourcemanager.ResourceManagerWSSEI {
    
    
    
    /*
     *  public constructor
     */
    public ResourceManagerWSSEI_Stub(HandlerChain handlerChain) {
        super(handlerChain);
        _setProperty(ENDPOINT_ADDRESS_PROPERTY, "REPLACE_WITH_ACTUAL_URL");
    }
    
    
    /*
     *  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.resourcemanager.Ping _myPing = new jwsgrid.ws.resourcemanager.Ping();
            
            SOAPBlockInfo _bodyBlock = new SOAPBlockInfo(ns1_ping_ping_QNAME);
            _bodyBlock.setValue(_myPing);
            _bodyBlock.setSerializer(ns1_myPing_LiteralSerializer);
            _request.setBody(_bodyBlock);
            
            _state.getMessageContext().setProperty(HttpClientTransport.HTTP_SOAPACTION_PROPERTY, "");
            
            _send((String) _getProperty(ENDPOINT_ADDRESS_PROPERTY), _state);
            
            jwsgrid.ws.resourcemanager.PingResponse _result = null;
            Object _responseObj = _state.getResponse().getBody().getValue();
            if (_responseObj instanceof SOAPDeserializationState) {
                _result = (jwsgrid.ws.resourcemanager.PingResponse)((SOAPDeserializationState) _responseObj).getInstance();
            } else {
                _result = (jwsgrid.ws.resourcemanager.PingResponse)_responseObj;
            }
            
            return _result.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 unregisterJobHost
     */
    public boolean unregisterJobHost(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(unregisterJobHost_OPCODE);
            
            jwsgrid.ws.resourcemanager.UnregisterJobHost _myUnregisterJobHost = new jwsgrid.ws.resourcemanager.UnregisterJobHost();
            _myUnregisterJobHost.setString_1(string_1);
            _myUnregisterJobHost.setString_2(string_2);
            
            SOAPBlockInfo _bodyBlock = new SOAPBlockInfo(ns1_unregisterJobHost_unregisterJobHost_QNAME);
            _bodyBlock.setValue(_myUnregisterJobHost);
            _bodyBlock.setSerializer(ns1_myUnregisterJobHost_LiteralSerializer);
            _request.setBody(_bodyBlock);
            
            _state.getMessageContext().setProperty(HttpClientTransport.HTTP_SOAPACTION_PROPERTY, "");
            
            _send((String) _getProperty(ENDPOINT_ADDRESS_PROPERTY), _state);
            
            jwsgrid.ws.resourcemanager.UnregisterJobHostResponse _result = null;
            Object _responseObj = _state.getResponse().getBody().getValue();
            if (_responseObj instanceof SOAPDeserializationState) {
                _result = (jwsgrid.ws.resourcemanager.UnregisterJobHostResponse)((SOAPDeserializationState) _responseObj).getInstance();
            } else {
                _result = (jwsgrid.ws.resourcemanager.UnregisterJobHostResponse)_responseObj;
            }
            
            return _result.isResult();
            
        } 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 registerJobHost
     */
    public void registerJobHost(java.lang.String string_1, java.lang.String string_2, java.lang.String string_3, java.lang.String string_4)
        throws java.rmi.RemoteException {
        
        try {
            
            StreamingSenderState _state = _start(_handlerChain);
            
            InternalSOAPMessage _request = _state.getRequest();
            _request.setOperationCode(registerJobHost_OPCODE);
            
            jwsgrid.ws.resourcemanager.RegisterJobHost _myRegisterJobHost = new jwsgrid.ws.resourcemanager.RegisterJobHost();
            _myRegisterJobHost.setString_1(string_1);
            _myRegisterJobHost.setString_2(string_2);
            _myRegisterJobHost.setString_3(string_3);
            _myRegisterJobHost.setString_4(string_4);
            
            SOAPBlockInfo _bodyBlock = new SOAPBlockInfo(ns1_registerJobHost_registerJobHost_QNAME);
            _bodyBlock.setValue(_myRegisterJobHost);
            _bodyBlock.setSerializer(ns1_myRegisterJobHost_LiteralSerializer);
            _request.setBody(_bodyBlock);
            
            _state.getMessageContext().setProperty(HttpClientTransport.HTTP_SOAPACTION_PROPERTY, "");
            
            _send((String) _getProperty(ENDPOINT_ADDRESS_PROPERTY), _state);
            
            
        } 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 searchJobHosts
     */
    public java.lang.String searchJobHosts(java.lang.String string_1)
        throws jwsgrid.ws.resourcemanager.ConstraintMatchException, jwsgrid.ws.resourcemanager.ConstraintDistanceException, java.rmi.RemoteException {
        
        try {
            
            StreamingSenderState _state = _start(_handlerChain);
            
            InternalSOAPMessage _request = _state.getRequest();
            _request.setOperationCode(searchJobHosts_OPCODE);
            
            jwsgrid.ws.resourcemanager.SearchJobHosts _mySearchJobHosts = new jwsgrid.ws.resourcemanager.SearchJobHosts();
            _mySearchJobHosts.setString_1(string_1);
            
            SOAPBlockInfo _bodyBlock = new SOAPBlockInfo(ns1_searchJobHosts_searchJobHosts_QNAME);
            _bodyBlock.setValue(_mySearchJobHosts);
            _bodyBlock.setSerializer(ns1_mySearchJobHosts_LiteralSerializer);
            _request.setBody(_bodyBlock);
            
            _state.getMessageContext().setProperty(HttpClientTransport.HTTP_SOAPACTION_PROPERTY, "");
            
            _send((String) _getProperty(ENDPOINT_ADDRESS_PROPERTY), _state);
            
            jwsgrid.ws.resourcemanager.SearchJobHostsResponse _result = null;
            Object _responseObj = _state.getResponse().getBody().getValue();