List of invokeBlocking() Examples

Examples of invokeBlocking()

org.apache.axis2.client.Call.invokeBlocking()
Invokes the blocking/synchronous call. @param axisop - this is used to identify the operation on the client side explicitly. @param toSend - data to be sent (OMElement). @return Returns OMElement. @throws AxisFault
org.apache.axis2.client.InOutMEPClient.invokeBlocking()
This method is used to make blocking calls. This is independent of the transport. For e.g. invocation done with this method might
1. send request via http and receive the response at the same http connection.
2. send request via http and receive the response at a different http connection.
3. send request via an email smtp and receive the response via an email.
org.apache.axis2.client.RESTCall.invokeBlocking()
org.apache.axis2.clientapi.Call.invokeBlocking()
Invoke the blocking/Synchronous call @param axisop - this will be used to identify the operation in the client side, without dispatching @param toSend - This should be OM Element (payload) @return @throws AxisFault
org.apache.axis2.clientapi.InOutMEPClient.invokeBlocking()
This invocation done via this method blocks till the result arrives, using this method does not indicate anyhting about the transport used or the nature of the transport. e.g. invocation done with this method might
1. send request via http and recevie the response via the return path of the same http connection
2. send request via http and recevie the response different http connection
3. send request via a email smtp and recevie the response via a email
org.apache.axis2.clientapi.RESTCall.invokeBlocking()
org.apache.axis2.rpc.client.RPCCall.invokeBlocking()
Return value can be a single a object or an object array (itself an object) , but it is difficulty to figure the return object correctly unless we have TyepMapping in the client side too. Until it is finalized lets return OMElement as return value. And the retuen value will be the body first element user has to deal with that and create his own object out of that. @param opName Operation QName (to get the body wrapper element) @param args Arraylist of objects @return Response OMElement
org.apache.axis2.rpc.client.RPCServiceClient.invokeBlocking()
Return value can be a single a object or an object array (itself an object) , but it is difficulty to figure the return object correctly unless we have TyepMapping in the client side too. Until it is finalized lets return OMElement as return value. And the retuen value will be the body first element user has to deal with that and create his own object out of that. @param opName Operation QName (to get the body wrapper element) @param args Arraylist of objects @return Response OMElement @throws AxisFault in case of a problem - this can either be a processing fault or a receivedon-the-wire fault.
org.apache.ode.bpel.iapi.MyRoleMessageExchange.invokeBlocking()
Invoke a process hosted by the BPEL engine, blocking until the operation completes. @return the final status of the operation

Examples of org.apache.axis2.rpc.client.RPCServiceClient.invokeBlocking()

        ArrayList args = new ArrayList();
        String [] values = new String[] { "abc", "cde", "efg" };
        args.add(values);
        ArrayList ret = new ArrayList();
        ret.add(Boolean.class);
        Object [] objs = sender.invokeBlocking(new QName("http://rpc.axis2.apache.org", "handleStringArray", "req"), args.toArray(),
                                               (Class[])ret.toArray(new Class[ret.size()]));
        assertNotNull(objs);
        assertEquals(Boolean.TRUE, Boolean.valueOf(objs[0].toString()));
    }

View Full Code Here

Examples of org.apache.axis2.rpc.client.RPCServiceClient.invokeBlocking()

        args.add(values3);
        args.add("10");


        ArrayList ret = new ArrayList();
        ret.add(Integer.class);
        Object [] objs = sender.invokeBlocking(new QName("http://rpc.axis2.apache.org", "multiArrays", "req"), args.toArray(),
                                               (Class[])ret.toArray(new Class[ret.size()]));
        assertNotNull(objs);
        assertEquals(19, Integer.parseInt(objs[0].toString()));
    }

View Full Code Here

Examples of org.apache.axis2.rpc.client.RPCServiceClient.invokeBlocking()


        ArrayList args = new ArrayList();
        args.add("foo");




        OMElement element = sender.invokeBlocking(new QName("http://rpc.axis2.apache.org", "mulReturn", "req"), args.toArray());
        System.out.println("element = " + element);
//        assertEquals(response.getFirstElement().getText(), "foo");
    }

View Full Code Here

Examples of org.apache.axis2.rpc.client.RPCServiceClient.invokeBlocking()


        Object[] opGetWeatherArgs = new Object[] { };
        Class[] returnTypes = new Class[] { Weather.class };
        
        
        Object[] response = serviceClient.invokeBlocking(opGetWeather,
                opGetWeatherArgs, returnTypes);
        
        Weather result = (Weather) response[0];
        
        // display results

View Full Code Here

Examples of org.apache.axis2.rpc.client.RPCServiceClient.invokeBlocking()


        ArrayList args = new ArrayList();
        args.add(bean);
        args.add("159");


        OMElement response = sender.invokeBlocking(new QName("http://rpc.axis2.apache.org", "editBean", "req"), args.toArray());
        MyBean resBean = (MyBean)BeanUtil.deserialize(MyBean.class, response.getFirstElement(),
                                                      new DefaultObjectSupplier(), null);
        assertNotNull(resBean);
        assertEquals(resBean.getAge(), 159);
    }

View Full Code Here

Examples of org.apache.axis2.rpc.client.RPCServiceClient.invokeBlocking()


        ArrayList args = new ArrayList();
        args.add(bean);




        OMElement response = sender.invokeBlocking(new QName("http://rpc.axis2.apache.org", "echoBean", "req"), args.toArray());
        MyBean resBean = (MyBean)BeanUtil.deserialize(MyBean.class,
                                                      response.getFirstElement(),
                                                      new DefaultObjectSupplier(), null);
//        MyBean resBean =(MyBean) new  BeanSerializer(MyBean.class,response).deserilze();
        assertNotNull(resBean);

View Full Code Here

Examples of org.apache.axis2.rpc.client.RPCServiceClient.invokeBlocking()


        ArrayList args = new ArrayList();
        args.add(mail);




        OMElement response = sender.invokeBlocking(new QName("http://rpc.axis2.apache.org", "echoMail", "req"), args.toArray());
        Mail resBean = (Mail)BeanUtil.deserialize(Mail.class, response.getFirstElement(),
                                                  new DefaultObjectSupplier(), null);
//        MyBean resBean =(MyBean) new  BeanSerializer(MyBean.class,response).deserilze();
        assertNotNull(resBean);
        assertEquals(resBean.getBody(), "My Body");

View Full Code Here

Examples of org.apache.axis2.rpc.client.RPCServiceClient.invokeBlocking()

    public void testEchoString() throws AxisFault {
      RPCServiceClient sender = getRPCClient("EchoXMLService", "echoString");


        ArrayList args = new ArrayList();
        args.add("foo");
        OMElement response = sender.invokeBlocking(new QName("http://rpc.axis2.apache.org", "echoString", "req"), args.toArray());
        assertEquals(response.getFirstElement().getText(), "foo");
    }


    public void testEchoInt() throws AxisFault {
      RPCServiceClient sender = getRPCClient("EchoXMLService", "echoInt");

View Full Code Here

Examples of org.apache.axis2.rpc.client.RPCServiceClient.invokeBlocking()

      RPCServiceClient sender = getRPCClient("EchoXMLService", "echoInt");


        ArrayList args = new ArrayList();
        args.add("100");


        OMElement response = sender.invokeBlocking(new QName("http://rpc.axis2.apache.org", "echoInt", "req"), args.toArray());
        assertEquals(Integer.parseInt(response.getFirstElement().getText()), 100);
    }


    public void testAdd() throws AxisFault {
      RPCServiceClient sender = getRPCClient("EchoXMLService", "add");

View Full Code Here

Examples of org.apache.axis2.rpc.client.RPCServiceClient.invokeBlocking()

      
        ArrayList args = new ArrayList();
        args.add("100");
        args.add("200");


        OMElement response = sender.invokeBlocking(new QName("http://rpc.axis2.apache.org", "add", "req"), args.toArray());
        assertEquals(Integer.parseInt(response.getFirstElement().getText()), 300);
    }


    public void testByteArray() throws AxisFault {
      RPCServiceClient sender = getRPCClient("EchoXMLService", "testByteArray");

View Full Code Here

0 1 2 3 4 5

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.