// This class was generated by the JAXRPC SI, do not edit. // Contents subject to change without notice. // JAX-RPC Standard Implementation (1.1.3, build R1) // Generated source version: 1.1.3 package build; 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 NgappbetPort_SubmitJob_Stub extends com.sun.xml.rpc.client.StubBase implements build.NgappbetPort { /* * public constructor */ public NgappbetPort_SubmitJob_Stub(HandlerChain handlerChain) { super(handlerChain); _setProperty(ENDPOINT_ADDRESS_PROPERTY, "http://ngdevelop3.cs.ucl.ac.uk:8080/ngappbet/SubmitJob"); } /* * implementation of submitJob0 */ public java.lang.String submitJob0(java.lang.String submit) throws java.rmi.RemoteException { try { StreamingSenderState _state = _start(_handlerChain); InternalSOAPMessage _request = _state.getRequest(); _request.setOperationCode(submitJob0_OPCODE); build.SubmitJob _mySubmitJob = new build.SubmitJob(); _mySubmitJob.setSubmit(submit); SOAPBlockInfo _bodyBlock = new SOAPBlockInfo(ns1_submitJob0_submitJob_QNAME); _bodyBlock.setValue(_mySubmitJob); _bodyBlock.setSerializer(ns1_mySubmitJob_LiteralSerializer); _request.setBody(_bodyBlock); _state.getMessageContext().setProperty(HttpClientTransport.HTTP_SOAPACTION_PROPERTY, ""); _send((java.lang.String) _getProperty(ENDPOINT_ADDRESS_PROPERTY), _state); build.SubmitJobResponse _result = null; java.lang.Object _responseObj = _state.getResponse().getBody().getValue(); if (_responseObj instanceof SOAPDeserializationState) { _result = (build.SubmitJobResponse)((SOAPDeserializationState) _responseObj).getInstance(); } else { _result = (build.SubmitJobResponse)_responseObj; } return _result.getSubmitRe(); } 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 submitJob */ public java.lang.String submitJob(java.lang.String submit) throws build.AuthorisationFaultMessage, build.JobSubmissionFaultMessage, java.rmi.RemoteException { try { StreamingSenderState _state = _start(_handlerChain); InternalSOAPMessage _request = _state.getRequest(); _request.setOperationCode(submitJob_OPCODE); build.SubmitJob _mySubmitJob = new build.SubmitJob(); _mySubmitJob.setSubmit(submit); SOAPBlockInfo _bodyBlock = new SOAPBlockInfo(ns1_submitJob_submitJob_QNAME); _bodyBlock.setValue(_mySubmitJob); _bodyBlock.setSerializer(ns1_mySubmitJob_LiteralSerializer); _request.setBody(_bodyBlock); _state.getMessageContext().setProperty(HttpClientTransport.HTTP_SOAPACTION_PROPERTY, ""); _send((java.lang.String) _getProperty(ENDPOINT_ADDRESS_PROPERTY), _state); build.SubmitJobResponse _result = null; java.lang.Object _responseObj = _state.getResponse().getBody().getValue(); if (_responseObj instanceof SOAPDeserializationState) { _result = (build.SubmitJobResponse)((SOAPDeserializationState) _responseObj).getInstance(); } else { _result = (build.SubmitJobResponse)_responseObj; } return _result.getSubmitRe(); } catch (build.AuthorisationFaultMessage e) { throw e; } catch (build.JobSubmissionFaultMessage e) { throw e; } catch (RemoteException e) { if (e.detail instanceof com.sun.xml.rpc.util.HeaderFaultException) { com.sun.xml.rpc.util.HeaderFaultException hfe = (com.sun.xml.rpc.util.HeaderFaultException) e.detail; SOAPHeaderBlockInfo headerBlock = (SOAPHeaderBlockInfo) hfe.getObject(); java.lang.Object obj = headerBlock.getValue(); } // 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 submitJob0_OPCODE: _deserialize_submitJob0(bodyReader, deserializationContext, state); break; case submitJob_OPCODE: _deserialize_submitJob(bodyReader, deserializationContext, state); break; default: throw new SenderException("sender.response.unrecognizedOperation", java.lang.Integer.toString(opcode)); } } /* * This method deserializes the body of the submitJob0 operation. */ private void _deserialize_submitJob0(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingSenderState state) throws Exception { java.lang.Object mySubmitJobResponseObj = ns1_mySubmitJobResponse_LiteralSerializer.deserialize(ns1_submitJob0_submitJobResponse_QNAME, bodyReader, deserializationContext); SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_submitJob0_submitJobResponse_QNAME); bodyBlock.setValue(mySubmitJobResponseObj); state.getResponse().setBody(bodyBlock); } /* * This method deserializes the body of the submitJob operation. */ private void _deserialize_submitJob(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingSenderState state) throws Exception { java.lang.Object mySubmitJobResponseObj = ns1_mySubmitJobResponse_LiteralSerializer.deserialize(ns1_submitJob_submitJobResponse_QNAME, bodyReader, deserializationContext); SOAPBlockInfo bodyBlock = new SOAPBlockInfo(ns1_submitJob_submitJobResponse_QNAME); bodyBlock.setValue(mySubmitJobResponseObj); state.getResponse().setBody(bodyBlock); } /* * this method deserializes fault responses */ protected Object _readBodyFaultElement(XMLReader bodyReader, SOAPDeserializationContext deserializationContext, StreamingSenderState state) throws Exception { Object faultInfo = null; int opcode = state.getRequest().getOperationCode(); switch (opcode) { case submitJob_OPCODE: faultInfo = myNgappbetPort_submitJob_Fault_SOAPSerializer.deserialize(null, bodyReader, deserializationContext); break; default: return super._readBodyFaultElement(bodyReader, deserializationContext, state); } return faultInfo; } protected java.lang.String _getDefaultEnvelopeEncodingStyle() { return null; } public java.lang.String _getImplicitEnvelopeEncodingStyle() { return ""; } public java.lang.String _getEncodingStyle() { return SOAPNamespaceConstants.ENCODING; } public void _setEncodingStyle(java.lang.String encodingStyle) { throw new UnsupportedOperationException("cannot set encoding style"); } /* * This method returns an array containing (prefix, nsURI) pairs. */ protected java.lang.String[] _getNamespaceDeclarations() { return myNamespace_declarations; } /* * This method returns an array containing the names of the headers we understand. */ public javax.xml.namespace.QName[] _getUnderstoodHeaders() { return understoodHeaderNames; } protected void _preHandlingHook(StreamingSenderState state) throws Exception { super._preHandlingHook(state); } protected boolean _preRequestSendingHook(StreamingSenderState state) throws Exception { boolean bool = false; bool = super._preRequestSendingHook(state); return bool; } public void _initialize(InternalTypeMappingRegistry registry) throws Exception { super._initialize(registry); ns1_mySubmitJob_LiteralSerializer = (CombinedSerializer)registry.getSerializer("", build.SubmitJob.class, ns1_submitJob_TYPE_QNAME); ns1_mySubmitJobResponse_LiteralSerializer = (CombinedSerializer)registry.getSerializer("", build.SubmitJobResponse.class, ns1_submitJobResponse_TYPE_QNAME); ((Initializable)myNgappbetPort_submitJob_Fault_SOAPSerializer).initialize(registry); } private static final javax.xml.namespace.QName _portName = new QName("http://www.neurogrid.ac.uk/Ngappbet", "SubmitJob"); private static final int submitJob0_OPCODE = 0; private static final int submitJob_OPCODE = 1; private final CombinedSerializer myNgappbetPort_submitJob_Fault_SOAPSerializer = new ReferenceableSerializerImpl(DONT_SERIALIZE_AS_REF, new build.NgappbetPort_submitJob_Fault_SOAPSerializer(ENCODE_TYPE, NOT_NULLABLE)); private static final javax.xml.namespace.QName ns1_submitJob0_submitJob_QNAME = new QName("http://www.neurogrid.ac.uk/Ngappbet", "submitJob"); private static final javax.xml.namespace.QName ns1_submitJob_TYPE_QNAME = new QName("http://www.neurogrid.ac.uk/Ngappbet", "submitJob"); private CombinedSerializer ns1_mySubmitJob_LiteralSerializer; private static final javax.xml.namespace.QName ns1_submitJob0_submitJobResponse_QNAME = new QName("http://www.neurogrid.ac.uk/Ngappbet", "submitJobResponse"); private static final javax.xml.namespace.QName ns1_submitJobResponse_TYPE_QNAME = new QName("http://www.neurogrid.ac.uk/Ngappbet", "submitJobResponse"); private CombinedSerializer ns1_mySubmitJobResponse_LiteralSerializer; private static final javax.xml.namespace.QName ns1_submitJob_submitJob_QNAME = new QName("http://www.neurogrid.ac.uk/Ngappbet", "submitJob"); private static final javax.xml.namespace.QName ns1_submitJob_submitJobResponse_QNAME = new QName("http://www.neurogrid.ac.uk/Ngappbet", "submitJobResponse"); private static final java.lang.String[] myNamespace_declarations = new java.lang.String[] { "ns0", "http://www.neurogrid.ac.uk/Ngappbet" }; private static final QName[] understoodHeaderNames = new QName[] { }; }