Repository: cxf Updated Branches: refs/heads/3.1.x-fixes b9e0f788b -> cbe9047c6
Making sure JettyHttpDestination can use Servlet3Continuation if possible Project: http://git-wip-us.apache.org/repos/asf/cxf/repo Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/cbe9047c Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/cbe9047c Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/cbe9047c Branch: refs/heads/3.1.x-fixes Commit: cbe9047c693b25af5bf26dc9e99ab721fbae8c31 Parents: b9e0f78 Author: Sergey Beryozkin <[email protected]> Authored: Tue Dec 6 13:30:40 2016 +0000 Committer: Sergey Beryozkin <[email protected]> Committed: Tue Dec 6 13:33:16 2016 +0000 ---------------------------------------------------------------------- .../apache/cxf/transport/http_jetty/JettyHTTPDestination.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cxf/blob/cbe9047c/rt/transports/http-jetty/src/main/java/org/apache/cxf/transport/http_jetty/JettyHTTPDestination.java ---------------------------------------------------------------------- diff --git a/rt/transports/http-jetty/src/main/java/org/apache/cxf/transport/http_jetty/JettyHTTPDestination.java b/rt/transports/http-jetty/src/main/java/org/apache/cxf/transport/http_jetty/JettyHTTPDestination.java index 7dfaac6..16eb0e9 100644 --- a/rt/transports/http-jetty/src/main/java/org/apache/cxf/transport/http_jetty/JettyHTTPDestination.java +++ b/rt/transports/http-jetty/src/main/java/org/apache/cxf/transport/http_jetty/JettyHTTPDestination.java @@ -368,8 +368,11 @@ public class JettyHTTPDestination extends ServletDestination { final HttpServletRequest req, final HttpServletResponse resp) { if (engine != null && engine.getContinuationsEnabled()) { - inMessage.put(ContinuationProvider.class.getName(), - new JettyContinuationProvider(req, resp, inMessage)); + super.setupContinuation(inMessage, req, resp); + if (!inMessage.containsKey(ContinuationProvider.class.getName())) { + inMessage.put(ContinuationProvider.class.getName(), + new JettyContinuationProvider(req, resp, inMessage)); + } } }
