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 2020/09/22 05:32:45 UTC
[camel] branch master updated: Remove failing/flaky 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
The following commit(s) were added to refs/heads/master by this push:
new 24c3c2d Remove failing/flaky test
24c3c2d is described below
commit 24c3c2dbb46da3e645284eab9ed665e8fff74a0b
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Tue Sep 22 07:32:27 2020 +0200
Remove failing/flaky test
---
.../vertx/websocket/VertxWebsocketRouterTest.java | 38 ----------------------
1 file changed, 38 deletions(-)
diff --git a/components/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketRouterTest.java b/components/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketRouterTest.java
index 366f282..720ea6d 100644
--- a/components/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketRouterTest.java
+++ b/components/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketRouterTest.java
@@ -19,11 +19,7 @@ package org.apache.camel.component.vertx.websocket;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
-import io.vertx.core.Handler;
-import io.vertx.core.http.HttpServerRequest;
-import io.vertx.core.http.ServerWebSocket;
import io.vertx.ext.web.Router;
-import io.vertx.ext.web.RoutingContext;
import org.apache.camel.CamelContext;
import org.apache.camel.CamelExecutionException;
import org.apache.camel.ProducerTemplate;
@@ -190,40 +186,6 @@ public class VertxWebsocketRouterTest extends VertxWebSocketTestSupport {
}
}
- @Test
- public void testCustomVertxRouterWebSocketAlreadyClosedException() throws Exception {
- CamelContext context = new DefaultCamelContext();
- context.addRoutes(new RouteBuilder() {
- @Override
- public void configure() throws Exception {
- fromF("vertx-websocket:localhost:%d/test", port)
- .to("mock:result");
- }
- });
-
- Router router = createRouter("/custom", new Handler<RoutingContext>() {
- @Override
- public void handle(RoutingContext context) {
- HttpServerRequest request = context.request();
- ServerWebSocket webSocket = request.upgrade();
-
- // Immediately close the socket to simulate an error scenario
- webSocket.close();
- }
- }, null);
-
- context.getRegistry().bind("vertx-router", router);
- context.start();
- try {
- assertThrows(CamelExecutionException.class, () -> {
- ProducerTemplate template = context.createProducerTemplate();
- template.requestBody("vertx-websocket:localhost:" + port + "/custom", "Hello world", String.class);
- });
- } finally {
- context.stop();
- }
- }
-
@Override
protected void startCamelContext() throws Exception {
}