You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2017/02/23 09:03:43 UTC
[07/10] camel git commit: CAMEL-10883: make stub source behave more
like the real HttpServerExchange class
CAMEL-10883: make stub source behave more like the real HttpServerExchange class
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/de3afdd0
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/de3afdd0
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/de3afdd0
Branch: refs/heads/master
Commit: de3afdd0f957da7f78cd7d9d7fe2cd97942a1637
Parents: 72bcb07
Author: rohan <ro...@fronde.com>
Authored: Tue Feb 21 15:24:24 2017 +1300
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Thu Feb 23 10:00:25 2017 +0100
----------------------------------------------------------------------
.../undertow/DefaultUndertowHttpBindingTest.java | 10 ++++++++++
1 file changed, 10 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/de3afdd0/components/camel-undertow/src/test/java/org/apache/camel/component/undertow/DefaultUndertowHttpBindingTest.java
----------------------------------------------------------------------
diff --git a/components/camel-undertow/src/test/java/org/apache/camel/component/undertow/DefaultUndertowHttpBindingTest.java b/components/camel-undertow/src/test/java/org/apache/camel/component/undertow/DefaultUndertowHttpBindingTest.java
index e8e1726..532ee9d 100644
--- a/components/camel-undertow/src/test/java/org/apache/camel/component/undertow/DefaultUndertowHttpBindingTest.java
+++ b/components/camel-undertow/src/test/java/org/apache/camel/component/undertow/DefaultUndertowHttpBindingTest.java
@@ -87,6 +87,16 @@ public class DefaultUndertowHttpBindingTest {
}
return 0;
}
+
+ @Override
+ public void resumeReads() {
+ /**
+ * {@link io.undertow.server.HttpServerExchange.ReadDispatchChannel} delays resumes in the main thread
+ */
+ if (sourceThread != Thread.currentThread()) {
+ super.resumeReads();
+ }
+ }
};
}