Examples of ClientCallback

Examples of org.apache.cxf.endpoint.ClientCallback

256
257
258
259
260
261
262
263
264
265
266
        if (params.length > 0 && params[params.length - 1] instanceof AsyncHandler) {
            handler = (AsyncHandler<Object>)params[params.length - 1];
        } else {
            handler = null;
        }
        ClientCallback callback = new JaxwsClientCallback<Object>(handler);
            
        Response<Object> ret = new JaxwsResponseCallback<Object>(callback);
        client.invoke(callback, oi, params);
        return ret;
    }
View Full Code Here

Examples of org.apache.cxf.endpoint.ClientCallback

1563
1564
1565
1566
1567
1568
1569
1570
1571
1572
1573
1574
1575
1576
1577
1578
1579
                in = ChunkedUtil.getPartialResponse(connection, responseCode);
                if (in == null) {
                    // oneway operation or decoupled MEP without
                    // partial response
                    connection.getInputStream().close();
                    ClientCallback cc = exchange.get(ClientCallback.class);
                    if (null != cc) {
                        //REVISIT move the decoupled destination property name into api
                        Endpoint ep = exchange.getEndpoint();
                        if (null != ep && null != ep.getEndpointInfo() && null == ep.getEndpointInfo().
                            getProperty("org.apache.cxf.ws.addressing.MAPAggregator.decoupledDestination")) {
                            cc.handleResponse(null, null);
                        }
                    }
                    return;
                }
            } else {
View Full Code Here

Examples of org.apache.cxf.endpoint.ClientCallback

243
244
245
246
247
248
249
250
251
252
253
        if (params.length > 0 && params[params.length - 1] instanceof AsyncHandler) {
            handler = (AsyncHandler)params[params.length - 1];
        } else {
            handler = null;
        }
        ClientCallback callback = new JaxwsClientCallback(handler);
            
        Response<Object> ret = new JaxwsResponseCallback(callback);
        client.invoke(callback, oi, params);
        return ret;
    }
View Full Code Here

Examples of org.apache.cxf.endpoint.ClientCallback

2326
2327
2328
2329
2330
2331
2332
2333
2334
2335
2336
2337
2338
2339
2340
2341
2342
                in = getPartialResponse(connection, responseCode);
                if (in == null) {
                    // oneway operation or decoupled MEP without
                    // partial response
                    connection.getInputStream().close();
                    ClientCallback cc = exchange.get(ClientCallback.class);
                    if (null != cc) {
                        //REVISIT move the decoupled destination property name into api
                        Endpoint ep = exchange.getEndpoint();
                        if (null != ep && null != ep.getEndpointInfo() && null == ep.getEndpointInfo().
                            getProperty("org.apache.cxf.ws.addressing.MAPAggregator.decoupledDestination")) {
                            cc.handleResponse(null, null);
                        }
                    }
                    return;
                }
            } else {
View Full Code Here

Examples of org.apache.cxf.endpoint.ClientCallback

246
247
248
249
250
251
252
253
254
255
256
        if (params.length > 0 && params[params.length - 1] instanceof AsyncHandler) {
            handler = (AsyncHandler)params[params.length - 1];
        } else {
            handler = null;
        }
        ClientCallback callback = new JaxwsClientCallback(handler);
            
        Response<Object> ret = new JaxwsResponseCallback(callback);
        client.invoke(callback, oi, params);
        return ret;
    }
View Full Code Here

Examples of org.apache.cxf.endpoint.ClientCallback

357
358
359
360
361
362
363
364
365
366
367
 
    public Future<?> invokeAsync(T obj, AsyncHandler<T> asyncHandler) {
        checkError();
        client.setExecutor(getClient().getEndpoint().getExecutor());

        ClientCallback callback = new JaxwsClientCallback<T>(asyncHandler);
            
        Response<T> ret = new JaxwsResponseCallback<T>(callback);
        try {
            QName opName = (QName)getRequestContext().get(MessageContext.WSDL_OPERATION);
            if (opName == null) {
View Full Code Here

Examples of org.apache.cxf.endpoint.ClientCallback

76
77
78
79
80
81
82
83
84
85
86
        parameters.setTargetType("tar-get");
        Object[] rparts = client.invoke("operation1", parameters, bucketOfBytes);
        Operation1Response r = (Operation1Response)rparts[0];
        assertEquals(md5(bucketOfBytes), r.getStatus());
       
        ClientCallback callback = new ClientCallback();
        client.invoke(callback, "operation1", parameters, bucketOfBytes);
        rparts = callback.get();
        r = (Operation1Response)rparts[0];
        assertEquals(md5(bucketOfBytes), r.getStatus());
    }
View Full Code Here

Examples of org.apache.cxf.endpoint.ClientCallback

343
344
345
346
347
348
349
350
351
352
353
 
    public Future<?> invokeAsync(T obj, AsyncHandler<T> asyncHandler) {
        checkError();
        client.setExecutor(getClient().getEndpoint().getExecutor());

        ClientCallback callback = new JaxwsClientCallback<T>(asyncHandler);
            
        Response<T> ret = new JaxwsResponseCallback<T>(callback);
        try {
            QName opName = (QName)getRequestContext().get(MessageContext.WSDL_OPERATION);
            if (opName == null) {
View Full Code Here

Examples of org.jacorb.test.ClientCallback

87
88
89
90
91
92
93
94
95
96
97

    @Test
    public void test_callback() throws Exception
    {
        ClientCallback c = ClientCallbackHelper.narrow (((BiDirSetup)setup).
                        getBiDirPOA().servant_to_reference(new ClientCallbackImpl()));

        server.register_callback (c);
        server.callback_hello ("This is a test");
        String result = waitForCallback (10000);
View Full Code Here

Examples of org.rzo.netty.ahessian.rpc.callback.ClientCallback

150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
  private void handleCallbackReply(CallbackReplyMessage message)
  {
    Long callbackId = message.getCallbackId();
    if (callbackId == null)
      return;
    ClientCallback callback = _callbacks.get(callbackId);
    if (callback == null)
    {
      System.out.println("no callback found for "+callbackId);
      return;
    }
    callback.invoke(message);
    if (message.isDone())
    {
      _callbacks.remove(callbackId);
      //System.out.println("removed callback "+callbackId);
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.