List of invokeAsync() Examples

Examples of invokeAsync()

javax.xml.ws.Dispatch.invokeAsync()
Invoke a service operation asynchronously. The method returns without waiting for the response to the operation invocation, the results of the operation are obtained by polling the returned Response.
The client is responsible for ensuring that the msg object when marshalled is formed according to the requirements of the protocol binding in use. @param msg An object that will form the message or payload ofthe message used to invoke the operation. @return The response message or message payload to theoperation invocation. @throws WebServiceException If there is any error in the configuration ofthe Dispatch instance
org.apache.axis2.jaxws.core.controller.AxisInvocationController.invokeAsync()
Note to developer: When making a change or fix to this method, please consider all 5 Proxy/Dispatch "invoke" methods now available in JAX-WS. For Dispatch, these are: 1) Synchronous invoke() 2) invokeOneWay() 3) invokeAsynch (Future) 4) invokeAsynch (Callback) For Proxy: 5) invokeSEIMethod()
org.apache.axis2.jaxws.core.controller.InvocationController.invokeAsync()
Performs an asynchronous (non-blocking) invocation of the client based on a callback model. The AsyncHandler that is passed in is the callback that the client programmer supplied when they invoked their JAX-WS Dispatch or their SEI-based dynamic proxy. @param ic @param callback @return
org.apache.axis2.jaxws.proxy.doclitnonwrapped.sei.DocLitnonWrappedProxy.invokeAsync()
@param allByMyself @return returns javax.xml.ws.Response
org.apache.axis2.jaxws.proxy.doclitwrapped.sei.DocLitWrappedProxy.invokeAsync()
@param invokeStr @return returns javax.xml.ws.Response
org.apache.axis2.jaxws.server.dispatcher.EndpointDispatcher.invokeAsync()
org.apache.tuscany.sca.runtime.RuntimeEndpoint.invokeAsync()
org.objectweb.celtix.transports.ClientTransport.invokeAsync()
invoke on a two-way operation on the remote service asyncronously. @param context @return the context containing the InputStream response payload

Examples of javax.xml.ws.Dispatch.invokeAsync()


   public void testInvokeAsynch() throws Exception
   {
      Source reqObj = new StreamSource(new StringReader(reqPayload));
      Dispatch dispatch = createDispatch();
      Response response = dispatch.invokeAsync(reqObj);
      verifyResponse((Source)response.get(3000, TimeUnit.MILLISECONDS));
   }


   public void testInvokeAsynchHandler() throws Exception
   {

View Full Code Here

Examples of javax.xml.ws.Dispatch.invokeAsync()

            }
         }
      };
      StreamSource reqObj = new StreamSource(new StringReader(reqPayload));
      Dispatch dispatch = createDispatch();
      Future future = dispatch.invokeAsync(reqObj, handler);
      future.get(1000, TimeUnit.MILLISECONDS);


      if (handlerException != null)
         throw handlerException;

View Full Code Here

Examples of javax.xml.ws.Dispatch.invokeAsync()

        numbers.setArg1(number2);


        JAXBElement<AddNumbers> addNumbers = factory.createAddNumbers(numbers);


        System.out.printf("\nInvoking async poll addNumbers(%d, %d)\n", number1, number2);
        Response<JAXBElement<AddNumbersResponse>> response = jaxbDispatch.invokeAsync(addNumbers);


        while (!response.isDone()) {
            //go do some work
        }

View Full Code Here

Examples of javax.xml.ws.Dispatch.invokeAsync()

        Dispatch sourceDispatch = null;
        sourceDispatch = service.createDispatch(portQName, Source.class, mode);


        System.out.println("\nInvoking async calback xml request: " + request);
        DispatchAsyncHandler handler = new DispatchAsyncHandler();
        Future<?> response = sourceDispatch.invokeAsync(new StreamSource(new StringReader(request)), new DispatchAsyncHandler());


        //go off and do something else
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {

View Full Code Here

Examples of javax.xml.ws.Dispatch.invokeAsync()


        JAXBElement<AddNumbers> addNumbers = factory.createAddNumbers(numbers);


        System.out.printf("\nInvoking async callback addNumbers(%d, %d)\n", number1, number2);
        DispatchAsyncHandler handler = new DispatchAsyncHandler();
        Future<?> response = jaxbDispatch.invokeAsync(addNumbers, handler);


        //go off and do other work
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {

View Full Code Here

Examples of javax.xml.ws.Dispatch.invokeAsync()

        Dispatch smDispatch = null;
        smDispatch = service.createDispatch(portQName, SOAPMessage.class, Service.Mode.MESSAGE);


        System.out.println("\nInvoking async callback message: " + msgString);
        DispatchAsyncHandler handler = new DispatchAsyncHandler();
        Future<?> response = smDispatch.invokeAsync(message, handler);


        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();

View Full Code Here

Examples of org.apache.axis2.jaxws.core.controller.AxisInvocationController.invokeAsync()

                }
            }


            requestIC.setExecutor(serviceDelegate.getExecutor());


            Future<?> future = controller.invokeAsync(requestIC, asyncHandler);


            //Check to see if we need to maintain session state
            checkMaintainSessionState(request, requestIC);


            return future;

View Full Code Here

Examples of org.apache.axis2.jaxws.core.controller.AxisInvocationController.invokeAsync()

            }
            AsyncResponse listener = createProxyListener(args, operationDesc);
            requestIC.setAsyncResponseListener(listener);
            requestIC.setExecutor(serviceDelegate.getExecutor());


            Response response = controller.invokeAsync(requestIC);


            //Check to see if we need to maintain session state
            checkMaintainSessionState(request, requestIC);


            return response;

View Full Code Here

Examples of org.apache.axis2.jaxws.core.controller.AxisInvocationController.invokeAsync()

                }
            }


            requestIC.setExecutor(serviceDelegate.getExecutor());


            Future<?> future = controller.invokeAsync(requestIC, asyncHandler);


            //Check to see if we need to maintain session state
            checkMaintainSessionState(request, requestIC);


            return future;

View Full Code Here

Examples of org.apache.axis2.jaxws.core.controller.AxisInvocationController.invokeAsync()

            }
            AsyncResponse listener = createProxyListener(args, operationDesc);
            requestIC.setAsyncResponseListener(listener);
            requestIC.setExecutor(serviceDelegate.getExecutor());


            Response response = controller.invokeAsync(requestIC);


            //Check to see if we need to maintain session state
            checkMaintainSessionState(request, requestIC);


            return response;

View Full Code Here

0 1 2 3 4

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.