You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2020/07/03 06:06:01 UTC

[camel] 01/02: CAMEL-14956: Fix vertx-websocket multi consumer test so that the producer sends to all intended paths

This is an automated email from the ASF dual-hosted git repository.

jamesnetherton pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 1b1f33571e0f773a3a8174b4ef27b1c1a5a4ce8c
Author: James Netherton <ja...@gmail.com>
AuthorDate: Fri Jul 3 06:27:37 2020 +0100

    CAMEL-14956: Fix vertx-websocket multi consumer test so that the producer sends to all intended paths
---
 .../component/vertx/websocket/VertxWebsocketMultiConsumerTest.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/components/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketMultiConsumerTest.java b/components/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketMultiConsumerTest.java
index be4f14e..86730e1 100644
--- a/components/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketMultiConsumerTest.java
+++ b/components/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketMultiConsumerTest.java
@@ -28,10 +28,10 @@ public class VertxWebsocketMultiConsumerTest extends VertxWebSocketTestSupport {
     @Test
     public void testMultipleConsumersForSameHostAndPort() throws Exception {
         MockEndpoint mockEndpoint = getMockEndpoint("mock:result");
-        mockEndpoint.expectedBodiesReceivedInAnyOrder("Hello A", "Hello B", "Hello C");
+        mockEndpoint.expectedBodiesReceivedInAnyOrder("Hello a", "Hello b", "Hello c");
 
-        Stream.of("A", "B", "C").forEach(body -> {
-            template.sendBody("vertx-websocket:localhost:" + port + "/test/a", body);
+        Stream.of("a", "b", "c").forEach(body -> {
+            template.sendBody("vertx-websocket:localhost:" + port + "/test/" + body, body);
         });
 
         mockEndpoint.assertIsSatisfied();