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 97A10200D69 for ; Wed, 27 Dec 2017 12:39:22 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 964B9160C23; Wed, 27 Dec 2017 11:39:22 +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 DD763160C20 for ; Wed, 27 Dec 2017 12:39:21 +0100 (CET) Received: (qmail 95827 invoked by uid 500); 27 Dec 2017 11:39:21 -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 95818 invoked by uid 99); 27 Dec 2017 11:39:21 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 27 Dec 2017 11:39:21 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 94F5D81AC3; Wed, 27 Dec 2017 11:39:19 +0000 (UTC) Date: Wed, 27 Dec 2017 11:39:19 +0000 To: "commits@cxf.apache.org" Subject: [cxf] branch master updated: [CXF-7556] Trying to use a json subscriber by default to avoid losing data for Flowable/Flux MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <151437475952.497.16922352829949267421@gitbox.apache.org> From: sergeyb@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: cxf X-Git-Refname: refs/heads/master X-Git-Reftype: branch X-Git-Oldrev: 07e1a175818695b048975e81f4db2b2756a9a209 X-Git-Newrev: 3bbcfd5d6caa343d664aa23326ff87cdb1b85d99 X-Git-Rev: 3bbcfd5d6caa343d664aa23326ff87cdb1b85d99 X-Git-NotificationType: ref_changed_plus_diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated archived-at: Wed, 27 Dec 2017 11:39:22 -0000 This is an automated email from the ASF dual-hosted git repository. sergeyb pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/cxf.git The following commit(s) were added to refs/heads/master by this push: new 3bbcfd5 [CXF-7556] Trying to use a json subscriber by default to avoid losing data for Flowable/Flux 3bbcfd5 is described below commit 3bbcfd5d6caa343d664aa23326ff87cdb1b85d99 Author: Sergey Beryozkin AuthorDate: Wed Dec 27 11:39:05 2017 +0000 [CXF-7556] Trying to use a json subscriber by default to avoid losing data for Flowable/Flux --- .../cxf/jaxrs/reactivestreams/server/AbstractReactiveInvoker.java | 2 +- .../java/org/apache/cxf/systest/jaxrs/reactor/ReactorServer.java | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/rt/rs/extensions/reactivestreams/src/main/java/org/apache/cxf/jaxrs/reactivestreams/server/AbstractReactiveInvoker.java b/rt/rs/extensions/reactivestreams/src/main/java/org/apache/cxf/jaxrs/reactivestreams/server/AbstractReactiveInvoker.java index e82166b..ee939fd 100644 --- a/rt/rs/extensions/reactivestreams/src/main/java/org/apache/cxf/jaxrs/reactivestreams/server/AbstractReactiveInvoker.java +++ b/rt/rs/extensions/reactivestreams/src/main/java/org/apache/cxf/jaxrs/reactivestreams/server/AbstractReactiveInvoker.java @@ -30,7 +30,7 @@ import org.reactivestreams.Publisher; public abstract class AbstractReactiveInvoker extends JAXRSInvoker { - private boolean useStreamingSubscriberIfPossible; + private boolean useStreamingSubscriberIfPossible = true; protected Object handleThrowable(AsyncResponseImpl asyncResponse, Throwable t) { diff --git a/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactor/ReactorServer.java b/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactor/ReactorServer.java index c056dbc..1a8fe27 100644 --- a/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactor/ReactorServer.java +++ b/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactor/ReactorServer.java @@ -42,7 +42,9 @@ public class ReactorServer extends AbstractBusTestServerBase { // Make sure default JSONProvider is not loaded bus.setProperty("skip.default.json.provider.registration", true); JAXRSServerFactoryBean sf = new JAXRSServerFactoryBean(); - sf.setInvoker(new ReactorInvoker()); + ReactorInvoker invoker = new ReactorInvoker(); + invoker.setUseStreamingSubscriberIfPossible(false); + sf.setInvoker(invoker); sf.setProvider(new JacksonJsonProvider()); StreamingResponseProvider streamProvider = new StreamingResponseProvider(); streamProvider.setProduceMediaTypes(Collections.singletonList("application/json")); @@ -57,9 +59,7 @@ public class ReactorServer extends AbstractBusTestServerBase { server1 = sf.create(); JAXRSServerFactoryBean sf2 = new JAXRSServerFactoryBean(); - ReactorInvoker invoker2 = new ReactorInvoker(); - invoker2.setUseStreamingSubscriberIfPossible(true); - sf2.setInvoker(invoker2); + sf2.setInvoker(new ReactorInvoker()); StreamingResponseProvider streamProvider2 = new StreamingResponseProvider(); streamProvider2.setProduceMediaTypes(Collections.singletonList("application/json")); sf2.setProvider(streamProvider2); -- To stop receiving notification emails like this one, please contact ['"commits@cxf.apache.org" '].