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

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


The following commit(s) were added to refs/heads/main by this push:
     new 4a478bdde48 (chores) camel-plc4x: fix test flakiness (#10906)
4a478bdde48 is described below

commit 4a478bdde4842f944d3f5722ee458a399af020da
Author: Otavio Rodolfo Piske <orpi...@users.noreply.github.com>
AuthorDate: Sat Jul 29 22:48:28 2023 +0200

    (chores) camel-plc4x: fix test flakiness (#10906)
    
    Send synchronously to avoid the unpredictable behavior of sending async and 
not checking the result
    
    Signed-off-by: Otavio R. Piske <angusyo...@gmail.com>
---
 .../java/org/apache/camel/component/plc4x/Plc4XComponentTagTest.java  | 4 ++--
 .../java/org/apache/camel/component/plc4x/Plc4XComponentTest.java     | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/components/camel-plc4x/src/test/java/org/apache/camel/component/plc4x/Plc4XComponentTagTest.java
 
b/components/camel-plc4x/src/test/java/org/apache/camel/component/plc4x/Plc4XComponentTagTest.java
index 9939e5b7565..19e0b3b2406 100644
--- 
a/components/camel-plc4x/src/test/java/org/apache/camel/component/plc4x/Plc4XComponentTagTest.java
+++ 
b/components/camel-plc4x/src/test/java/org/apache/camel/component/plc4x/Plc4XComponentTagTest.java
@@ -31,8 +31,8 @@ public class Plc4XComponentTagTest extends CamelTestSupport {
         MockEndpoint mock = getMockEndpoint("mock:result");
         mock.expectedMinimumMessageCount(1);
         mock.expectedMessageCount(2);
-        template.asyncSendBody("direct:plc4x", 
Collections.singletonList("irrelevant"));
-        template.asyncSendBody("direct:plc4x2", 
Collections.singletonList("irrelevant"));
+        template.sendBody("direct:plc4x", 
Collections.singletonList("irrelevant"));
+        template.sendBody("direct:plc4x2", 
Collections.singletonList("irrelevant"));
 
         MockEndpoint.assertIsSatisfied(context, 2, TimeUnit.SECONDS);
     }
diff --git 
a/components/camel-plc4x/src/test/java/org/apache/camel/component/plc4x/Plc4XComponentTest.java
 
b/components/camel-plc4x/src/test/java/org/apache/camel/component/plc4x/Plc4XComponentTest.java
index e42eadbc70d..ec56bc95b4c 100644
--- 
a/components/camel-plc4x/src/test/java/org/apache/camel/component/plc4x/Plc4XComponentTest.java
+++ 
b/components/camel-plc4x/src/test/java/org/apache/camel/component/plc4x/Plc4XComponentTest.java
@@ -31,8 +31,8 @@ public class Plc4XComponentTest extends CamelTestSupport {
         MockEndpoint mock = getMockEndpoint("mock:result");
         mock.expectedMinimumMessageCount(1);
         mock.expectedMessageCount(2);
-        template.asyncSendBody("direct:plc4x", 
Collections.singletonList("irrelevant"));
-        template.asyncSendBody("direct:plc4x2", 
Collections.singletonList("irrelevant"));
+        template.sendBody("direct:plc4x", 
Collections.singletonList("irrelevant"));
+        template.sendBody("direct:plc4x2", 
Collections.singletonList("irrelevant"));
 
         MockEndpoint.assertIsSatisfied(context, 2, TimeUnit.SECONDS);
     }

Reply via email to