You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by pa...@apache.org on 2017/11/14 20:32:01 UTC
[camel] branch master updated (b5ddb71 -> 8378f96)
This is an automated email from the ASF dual-hosted git repository.
pascalschumacher pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.
from b5ddb71 Add Maven Wrapper
new dac50e9 MemoryWebsocketStoreTest: remove unused import statements
new 8378f96 camel-websocket: try to make test pass on build.apache.org by increasing maximum threads from 20 to 25
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/camel/component/websocket/MemoryWebsocketStoreTest.java | 3 ---
.../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 +-
.../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 +-
.../camel/component/websocket/WebsocketTwoRoutesExampleTest.java | 2 +-
...WebsocketTwoRoutesToSIndividualAndBroadcastEndpointExampleTest.java | 2 +-
.../websocket/WebsocketTwoRoutesToSameEndpointExampleTest.java | 2 +-
15 files changed, 14 insertions(+), 17 deletions(-)
--
To stop receiving notification emails like this one, please contact
['"commits@camel.apache.org" <co...@camel.apache.org>'].
[camel] 02/02: camel-websocket: try to make test pass on
build.apache.org by increasing maximum threads from 20 to 25
Posted by pa...@apache.org.
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 <pa...@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" <co...@camel.apache.org>.
[camel] 01/02: MemoryWebsocketStoreTest: remove unused import
statements
Posted by pa...@apache.org.
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 dac50e952de42e364b3aa6c9d840c88adf023208
Author: Pascal Schumacher <pa...@gmx.net>
AuthorDate: Tue Nov 14 20:34:00 2017 +0100
MemoryWebsocketStoreTest: remove unused import statements
---
.../org/apache/camel/component/websocket/MemoryWebsocketStoreTest.java | 3 ---
1 file changed, 3 deletions(-)
diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/MemoryWebsocketStoreTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/MemoryWebsocketStoreTest.java
index 4e5eaf3..5a3b933 100644
--- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/MemoryWebsocketStoreTest.java
+++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/MemoryWebsocketStoreTest.java
@@ -20,7 +20,6 @@ import java.util.Collection;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
-import org.mockito.InOrder;
import org.mockito.Mock;
import org.mockito.runners.MockitoJUnitRunner;
@@ -29,8 +28,6 @@ import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
-import static org.mockito.Mockito.inOrder;
-import static org.mockito.Mockito.times;
import static org.mockito.Mockito.when;
/**
--
To stop receiving notification emails like this one, please contact
"commits@camel.apache.org" <co...@camel.apache.org>.