Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id E2DE9200B27 for ; Wed, 8 Jun 2016 03:48:13 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id E1875160A68; Wed, 8 Jun 2016 01:48:13 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 32543160A36 for ; Wed, 8 Jun 2016 03:48:13 +0200 (CEST) Received: (qmail 79006 invoked by uid 500); 8 Jun 2016 01:48:12 -0000 Mailing-List: contact commits-help@cxf.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@cxf.apache.org Delivered-To: mailing list commits@cxf.apache.org Received: (qmail 77652 invoked by uid 99); 8 Jun 2016 01:48:11 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 08 Jun 2016 01:48:11 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 38E1EE97D5; Wed, 8 Jun 2016 01:48:11 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: reta@apache.org To: commits@cxf.apache.org Date: Wed, 08 Jun 2016 01:48:22 -0000 Message-Id: <6e33e51fbd554a74b84bbbb187094fe0@git.apache.org> In-Reply-To: <73e307df32314c5ea2ef8bd3c658c23c@git.apache.org> References: <73e307df32314c5ea2ef8bd3c658c23c@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [12/22] cxf git commit: Adding a test with multiple JAXRS proxy callbacks archived-at: Wed, 08 Jun 2016 01:48:14 -0000 Adding a test with multiple JAXRS proxy callbacks Project: http://git-wip-us.apache.org/repos/asf/cxf/repo Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/94e99ce4 Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/94e99ce4 Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/94e99ce4 Branch: refs/heads/master-jaxrs-2.1 Commit: 94e99ce4ae6e6fb31790c2fb84b3541268fde62f Parents: 471f885 Author: Sergey Beryozkin Authored: Tue Jun 7 18:04:48 2016 +0100 Committer: Sergey Beryozkin Committed: Tue Jun 7 18:04:48 2016 +0100 ---------------------------------------------------------------------- .../cxf/systest/jaxrs/JAXRSAsyncClientTest.java | 38 ++++++++++++++++++++ 1 file changed, 38 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cxf/blob/94e99ce4/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/JAXRSAsyncClientTest.java ---------------------------------------------------------------------- diff --git a/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/JAXRSAsyncClientTest.java b/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/JAXRSAsyncClientTest.java index cd5580f..8713229 100644 --- a/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/JAXRSAsyncClientTest.java +++ b/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/JAXRSAsyncClientTest.java @@ -302,6 +302,44 @@ public class JAXRSAsyncClientTest extends AbstractBusClientServerTestBase { assertNotNull(holder.value); assertEquals(123L, holder.value.getId()); } + @Test + public void testAsyncProxyMultipleCallbacks() throws Exception { + String address = "http://localhost:" + PORT; + final Holder bookHolder = new Holder(); + final InvocationCallback bookCallback = new InvocationCallback() { + public void completed(Book response) { + bookHolder.value = response; + } + public void failed(Throwable error) { + } + }; + final Holder booleanHolder = new Holder(); + final InvocationCallback booleanCallback = new InvocationCallback() { + public void completed(Boolean response) { + booleanHolder.value = response; + } + public void failed(Throwable error) { + } + }; + List> callbacks = new ArrayList>(); + callbacks.add(bookCallback); + callbacks.add(booleanCallback); + + BookStore store = JAXRSClientFactory.create(address, BookStore.class); + WebClient.getConfig(store).getRequestContext().put(InvocationCallback.class.getName(), callbacks); + + + + Book book = store.getBookByMatrixParams("12", "3"); + assertNull(book); + Thread.sleep(3000); + assertNotNull(bookHolder.value); + assertEquals(123L, bookHolder.value.getId()); + + store.checkBook(123L); + Thread.sleep(3000); + assertTrue(booleanHolder.value); + } @SuppressWarnings({ "unchecked", "rawtypes"