This is an automated email from the ASF dual-hosted git repository. pascalschumacher pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 8378f96c11ea74313a942d3251975da0ecd7c6ec Author: Pascal Schumacher <pascalschumac...@gmx.net> AuthorDate: Tue Nov 14 21:31:34 2017 +0100 camel-websocket: try to make test pass on build.apache.org by increasing maximum threads from 20 to 25 --- .../apache/camel/component/websocket/WebsocketClientCamelRouteTest.java | 2 +- .../camel/component/websocket/WebsocketComponentRouteExampleTest.java | 2 +- .../apache/camel/component/websocket/WebsocketConsumerRouteTest.java | 2 +- .../camel/component/websocket/WebsocketEndpointConfigurationTest.java | 2 +- .../camel/component/websocket/WebsocketProducerRouteExampleTest.java | 2 +- .../camel/component/websocket/WebsocketProducerRouteRestartTest.java | 2 +- .../org/apache/camel/component/websocket/WebsocketRouteExampleTest.java | 2 +- .../component/websocket/WebsocketSSLContextGlobalRouteExampleTest.java | 2 +- .../component/websocket/WebsocketSSLContextInUriRouteExampleTest.java | 2 +- .../apache/camel/component/websocket/WebsocketSSLRouteExampleTest.java | 2 +- .../java/org/apache/camel/component/websocket/WebsocketStaticTest.java | 2 +- .../apache/camel/component/websocket/WebsocketTwoRoutesExampleTest.java | 2 +- .../WebsocketTwoRoutesToSIndividualAndBroadcastEndpointExampleTest.java | 2 +- .../websocket/WebsocketTwoRoutesToSameEndpointExampleTest.java | 2 +- 14 files changed, 14 insertions(+), 14 deletions(-) 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 d101fe7..ad701a1 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 @@ -98,7 +98,7 @@ public class WebsocketClientCamelRouteTest extends CamelTestSupport { WebsocketComponent websocketComponent = getContext().getComponent("websocket", WebsocketComponent.class); websocketComponent.setPort(port); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(20); + websocketComponent.setMaxThreads(25); from("websocket://test") .log(">>> Message received from WebSocket Client : ${body}") 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 910c305..db021c4 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 @@ -93,7 +93,7 @@ public class WebsocketComponentRouteExampleTest extends CamelTestSupport { WebsocketComponent websocketComponent = getContext().getComponent("websocket", WebsocketComponent.class); websocketComponent.setHost("localhost"); websocketComponent.setPort(port); - websocketComponent.setMaxThreads(20); + websocketComponent.setMaxThreads(25); websocketComponent.setMinThreads(1); from("websocket://echo") 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 72c6e12..80ddfa8 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 @@ -111,7 +111,7 @@ public class WebsocketConsumerRouteTest extends CamelTestSupport { public void configure() { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); websocketComponent.setPort(port); - websocketComponent.setMaxThreads(20); + websocketComponent.setMaxThreads(25); websocketComponent.setMinThreads(1); from("websocket://echo") diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketEndpointConfigurationTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketEndpointConfigurationTest.java index 69345ce..503f7b6 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketEndpointConfigurationTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketEndpointConfigurationTest.java @@ -43,7 +43,7 @@ public class WebsocketEndpointConfigurationTest extends CamelTestSupport { WebsocketEndpoint websocketEndpoint = (WebsocketEndpoint)context.getEndpoint(uri); WebsocketComponent component = websocketEndpoint.getComponent(); component.setMinThreads(1); - component.setMaxThreads(20); + component.setMaxThreads(25); Consumer consumer = websocketEndpoint.createConsumer(processor); component.connect((WebsocketProducerConsumer) consumer); 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 2c52cbd..bf4a0e8 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(20); + websocketComponent.setMaxThreads(25); websocketComponent.setMinThreads(1); from("direct:shop") .log(">>> Message received from Shopping center : ${body}") 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 24fc925..0036e19 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 @@ -122,7 +122,7 @@ public class WebsocketProducerRouteRestartTest extends CamelTestSupport { return new RouteBuilder() { public void configure() { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); - websocketComponent.setMaxThreads(20); + websocketComponent.setMaxThreads(25); websocketComponent.setMinThreads(1); from("direct:shop") .id(ROUTE_ID) 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 177b818..9a4e989 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 @@ -90,7 +90,7 @@ public class WebsocketRouteExampleTest extends CamelTestSupport { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); websocketComponent.setPort(port); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(20); + websocketComponent.setMaxThreads(25); // START SNIPPET: e1 // expose a echo websocket client, that sends back an echo diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLContextGlobalRouteExampleTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLContextGlobalRouteExampleTest.java index ebd2242..227283f 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLContextGlobalRouteExampleTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketSSLContextGlobalRouteExampleTest.java @@ -175,7 +175,7 @@ public class WebsocketSSLContextGlobalRouteExampleTest extends CamelTestSupport public void configure() { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(20); + websocketComponent.setMaxThreads(25); from(uri) .log(">>> Message received from WebSocket Client : ${body}") .to("mock:client") 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 235b641..ec44780 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 @@ -174,7 +174,7 @@ public class WebsocketSSLContextInUriRouteExampleTest extends CamelTestSupport { public void configure() { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(20); + websocketComponent.setMaxThreads(25); from(uri) .log(">>> Message received from WebSocket Client : ${body}") .to("mock:client") 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 768b448..5ced879 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 @@ -171,7 +171,7 @@ public class WebsocketSSLRouteExampleTest extends CamelTestSupport { websocketComponent.setSslContextParameters(defineSSLContextParameters()); websocketComponent.setPort(port); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(20); + websocketComponent.setMaxThreads(25); from("websocket://test") .log(">>> Message received from WebSocket Client : ${body}") diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketStaticTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketStaticTest.java index 0bb7065..d652be9 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketStaticTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketStaticTest.java @@ -101,7 +101,7 @@ public class WebsocketStaticTest extends CamelTestSupport { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); websocketComponent.setPort(port); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(20); + websocketComponent.setMaxThreads(25); websocketComponent.setStaticResources("classpath:."); // START SNIPPET: e1 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 fe01d21..cd1c5d4 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 @@ -132,7 +132,7 @@ public class WebsocketTwoRoutesExampleTest extends CamelTestSupport { public void configure() { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(20); + websocketComponent.setMaxThreads(25); from("websocket://localhost:" + port + "/bar") .log(">>> Message received from BAR WebSocket Client : ${body}") 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 9e4232e..59a14f3 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 @@ -95,7 +95,7 @@ public class WebsocketTwoRoutesToSIndividualAndBroadcastEndpointExampleTest exte public void configure() { WebsocketComponent websocketComponent = (WebsocketComponent) context.getComponent("websocket"); websocketComponent.setMinThreads(1); - websocketComponent.setMaxThreads(20); + websocketComponent.setMaxThreads(25); from("websocket://localhost:" + port + "/bar") .log(">>> Message received from BAR WebSocket Client : ${body}") 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 d486e53..d4aee1c 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(20); + websocketComponent.setMaxThreads(25); from("websocket://localhost:" + port + "/bar") .log(">>> Message received from BAR WebSocket Client : ${body}") -- To stop receiving notification emails like this one, please contact "commits@camel.apache.org" <commits@camel.apache.org>.