You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2019/11/11 05:16:10 UTC
[camel] 02/02: CAMEL-14137: Fixed test
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 9b616254761940f837100349a191aef58776e3c5
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Mon Nov 11 06:15:43 2019 +0100
CAMEL-14137: Fixed test
---
.../component/jetty/JettyThreadPoolSizeTest.java | 28 ++++------------------
1 file changed, 4 insertions(+), 24 deletions(-)
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyThreadPoolSizeTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyThreadPoolSizeTest.java
index 433b486..4866602 100644
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyThreadPoolSizeTest.java
+++ b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyThreadPoolSizeTest.java
@@ -24,42 +24,23 @@ import org.slf4j.LoggerFactory;
public class JettyThreadPoolSizeTest extends BaseJettyTest {
-
- private static final Logger LOG = LoggerFactory.getLogger(JettyThreadPoolSizeTest.class);
+ private static final Logger LOG = LoggerFactory.getLogger(JettyThreadPoolSizeTest.class);
@Test
public void threadPoolTest() {
-
long initialJettyThreadNumber = countJettyThread();
-
LOG.info("initial Jetty thread number (expected 5): " + initialJettyThreadNumber);
+ assertEquals(5, initialJettyThreadNumber);
context.stop();
- long jettyThreadNumberAfterStop = countJettyThread();
-
+ long jettyThreadNumberAfterStop = countJettyThread();
LOG.info("Jetty thread number after stopping Camel Context: (expected 0): " + jettyThreadNumberAfterStop);
-
- JettyHttpComponent jettyComponent = (JettyHttpComponent)context.getComponent("jetty");
- jettyComponent.setMinThreads(5);
- jettyComponent.setMaxThreads(5);
-
- context.start();
-
- long jettyThreadNumberAfterRestart = countJettyThread();
-
- LOG.info("Jetty thread number after starting Camel Context: (expected 5): " + jettyThreadNumberAfterRestart);
-
- assertEquals(5L, initialJettyThreadNumber);
-
- assertEquals(0L, jettyThreadNumberAfterStop);
-
- assertEquals(5L, jettyThreadNumberAfterRestart);
+ assertEquals(0, jettyThreadNumberAfterStop);
}
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
-
return new RouteBuilder() {
@Override
public void configure() throws Exception {
@@ -74,7 +55,6 @@ public class JettyThreadPoolSizeTest extends BaseJettyTest {
}
private long countJettyThread() {
-
Set<Thread> threadSet = Thread.getAllStackTraces().keySet();
return threadSet.stream().filter(thread -> thread.getName().contains("CamelJettyServer")).count();
}