Repository: camel Updated Branches: refs/heads/master e6da66a69 -> 9e756fefb
Camel-websocket: Fixed the maxThreads parameter in tests Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/9e756fef Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/9e756fef Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/9e756fef Branch: refs/heads/master Commit: 9e756fefbb053926754108335e3ad78b586439ac Parents: e6da66a Author: Andrea Cosentino <anco...@gmail.com> Authored: Fri Apr 22 08:32:03 2016 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Fri Apr 22 08:38:04 2016 +0200 ---------------------------------------------------------------------- .../org/apache/camel/component/websocket/WebsocketComponent.java | 2 +- .../component/websocket/WebscoketEndpointConfigurationTest.java | 2 +- .../camel/component/websocket/WebsocketClientCamelRouteTest.java | 2 +- .../component/websocket/WebsocketComponentRouteExampleTest.java | 2 +- .../camel/component/websocket/WebsocketConsumerRouteTest.java | 2 +- .../component/websocket/WebsocketProducerRouteExampleTest.java | 2 +- .../component/websocket/WebsocketProducerRouteRestartTest.java | 2 +- .../camel/component/websocket/WebsocketRouteExampleTest.java | 2 +- .../websocket/WebsocketSSLContextInUriRouteExampleTest.java | 2 +- .../camel/component/websocket/WebsocketSSLRouteExampleTest.java | 2 +- .../camel/component/websocket/WebsocketTwoRoutesExampleTest.java | 2 +- ...ocketTwoRoutesToSIndividualAndBroadcastEndpointExampleTest.java | 2 +- .../websocket/WebsocketTwoRoutesToSameEndpointExampleTest.java | 2 +- 13 files changed, 13 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/9e756fef/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java index b786319..90e0d8d 100644 --- a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java +++ b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java @@ -353,7 +353,7 @@ public class WebsocketComponent extends UriEndpointComponent { qtp.setMaxThreads(maxThreads.intValue()); } // let the thread names indicate they are from the server - qtp.setName("CamelJettyWebSocketServer(" + "test" + ")"); + qtp.setName("CamelJettyWebSocketServer"); try { qtp.start(); } catch (Exception e) { http://git-wip-us.apache.org/repos/asf/camel/blob/9e756fef/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebscoketEndpointConfigurationTest.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebscoketEndpointConfigurationTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebscoketEndpointConfigurationTest.java index 029529d..27e01ba 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebscoketEndpointConfigurationTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebscoketEndpointConfigurationTest.java @@ -44,7 +44,7 @@ public class WebscoketEndpointConfigurationTest extends CamelTestSupport { WebsocketEndpoint websocketEndpoint = (WebsocketEndpoint)context.getEndpoint(uri); WebsocketComponent component = websocketEndpoint.getComponent(); component.setMinThreads(1); - component.setMaxThreads(11); + component.setMaxThreads(20); Consumer consumer = websocketEndpoint.createConsumer(processor); component.connect((WebsocketProducerConsumer) consumer); http://git-wip-us.apache.org/repos/asf/camel/blob/9e756fef/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketClientCamelRouteTest.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketClientCamelRouteTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketClientCamelRouteTest.java index f226a27..c98f893 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketClientCamelRouteTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketClientCamelRouteTest.java @@ -97,7 +97,7 @@ public class WebsocketClientCamelRouteTest extends CamelTestSupport { WebsocketComponent websocketComponent = getContext().getComponent("websocket", WebsocketComponent.class); websocketComponent.setPort(port); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(11); + websocketComponent.setMaxThreads(20); from("websocket://test") .log(">>> Message received from WebSocket Client : ${body}") http://git-wip-us.apache.org/repos/asf/camel/blob/9e756fef/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketComponentRouteExampleTest.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketComponentRouteExampleTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketComponentRouteExampleTest.java index 76b14a0..211856f 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketComponentRouteExampleTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketComponentRouteExampleTest.java @@ -92,7 +92,7 @@ public class WebsocketComponentRouteExampleTest extends CamelTestSupport { WebsocketComponent websocketComponent = getContext().getComponent("websocket", WebsocketComponent.class); websocketComponent.setHost("localhost"); websocketComponent.setPort(port); - websocketComponent.setMaxThreads(11); + websocketComponent.setMaxThreads(20); websocketComponent.setMinThreads(1); from("websocket://echo") http://git-wip-us.apache.org/repos/asf/camel/blob/9e756fef/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketConsumerRouteTest.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketConsumerRouteTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketConsumerRouteTest.java index ea1874a..20b2f40 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketConsumerRouteTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketConsumerRouteTest.java @@ -109,7 +109,7 @@ public class WebsocketConsumerRouteTest extends CamelTestSupport { public void configure() { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); websocketComponent.setPort(port); - websocketComponent.setMaxThreads(11); + websocketComponent.setMaxThreads(20); websocketComponent.setMinThreads(1); from("websocket://echo") http://git-wip-us.apache.org/repos/asf/camel/blob/9e756fef/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketProducerRouteExampleTest.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketProducerRouteExampleTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketProducerRouteExampleTest.java index aea401a..513e71b 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketProducerRouteExampleTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketProducerRouteExampleTest.java @@ -146,7 +146,7 @@ public class WebsocketProducerRouteExampleTest extends CamelTestSupport { return new RouteBuilder() { public void configure() { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); - websocketComponent.setMaxThreads(11); + websocketComponent.setMaxThreads(20); websocketComponent.setMinThreads(1); from("direct:shop") .log(">>> Message received from Shopping center : ${body}") http://git-wip-us.apache.org/repos/asf/camel/blob/9e756fef/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketProducerRouteRestartTest.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketProducerRouteRestartTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketProducerRouteRestartTest.java index 3f9c4d2..e28ca29 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketProducerRouteRestartTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketProducerRouteRestartTest.java @@ -121,7 +121,7 @@ public class WebsocketProducerRouteRestartTest extends CamelTestSupport { return new RouteBuilder() { public void configure() { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); - websocketComponent.setMaxThreads(11); + websocketComponent.setMaxThreads(20); websocketComponent.setMinThreads(1); from("direct:shop") .id(ROUTE_ID) http://git-wip-us.apache.org/repos/asf/camel/blob/9e756fef/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketRouteExampleTest.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketRouteExampleTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketRouteExampleTest.java index 3606a27..d4b655c 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketRouteExampleTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketRouteExampleTest.java @@ -89,7 +89,7 @@ public class WebsocketRouteExampleTest extends CamelTestSupport { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); websocketComponent.setPort(port); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(11); + websocketComponent.setMaxThreads(20); // START SNIPPET: e1 // expose a echo websocket client, that sends back an echo http://git-wip-us.apache.org/repos/asf/camel/blob/9e756fef/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLContextInUriRouteExampleTest.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLContextInUriRouteExampleTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLContextInUriRouteExampleTest.java index 5f6e8d5..937fb76 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLContextInUriRouteExampleTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLContextInUriRouteExampleTest.java @@ -166,7 +166,7 @@ public class WebsocketSSLContextInUriRouteExampleTest extends CamelTestSupport { public void configure() { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(11); + websocketComponent.setMaxThreads(20); from(uri) .log(">>> Message received from WebSocket Client : ${body}") .to("mock:client") http://git-wip-us.apache.org/repos/asf/camel/blob/9e756fef/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLRouteExampleTest.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLRouteExampleTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLRouteExampleTest.java index 251cccc..f364b12 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLRouteExampleTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLRouteExampleTest.java @@ -162,7 +162,7 @@ public class WebsocketSSLRouteExampleTest extends CamelTestSupport { websocketComponent.setSslContextParameters(defineSSLContextParameters()); websocketComponent.setPort(port); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(11); + websocketComponent.setMaxThreads(20); from("websocket://test") .log(">>> Message received from WebSocket Client : ${body}") http://git-wip-us.apache.org/repos/asf/camel/blob/9e756fef/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesExampleTest.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesExampleTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesExampleTest.java index eb8d8f7..9a8c0cd 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesExampleTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesExampleTest.java @@ -131,7 +131,7 @@ public class WebsocketTwoRoutesExampleTest extends CamelTestSupport { public void configure() { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(11); + websocketComponent.setMaxThreads(20); from("websocket://localhost:" + port + "/bar") .log(">>> Message received from BAR WebSocket Client : ${body}") http://git-wip-us.apache.org/repos/asf/camel/blob/9e756fef/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesToSIndividualAndBroadcastEndpointExampleTest.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesToSIndividualAndBroadcastEndpointExampleTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesToSIndividualAndBroadcastEndpointExampleTest.java index d4aa92f..0b09f8a 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesToSIndividualAndBroadcastEndpointExampleTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesToSIndividualAndBroadcastEndpointExampleTest.java @@ -94,7 +94,7 @@ public class WebsocketTwoRoutesToSIndividualAndBroadcastEndpointExampleTest exte public void configure() { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(11); + websocketComponent.setMaxThreads(20); from("websocket://localhost:" + port + "/bar") .log(">>> Message received from BAR WebSocket Client : ${body}") http://git-wip-us.apache.org/repos/asf/camel/blob/9e756fef/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesToSameEndpointExampleTest.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesToSameEndpointExampleTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesToSameEndpointExampleTest.java index 7c0b145..677eb53 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesToSameEndpointExampleTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketTwoRoutesToSameEndpointExampleTest.java @@ -94,7 +94,7 @@ public class WebsocketTwoRoutesToSameEndpointExampleTest extends CamelTestSuppor public void configure() { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(11); + websocketComponent.setMaxThreads(20); from("websocket://localhost:" + port + "/bar") .log(">>> Message received from BAR WebSocket Client : ${body}")
