You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by dm...@apache.org on 2019/06/26 19:17:30 UTC
[camel] 07/12: CAMEL-13209 Fixing intermittent failure by
increasing the sleep time of the main thread
This is an automated email from the ASF dual-hosted git repository.
dmvolod pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 993752933edcc54fa155265ad7e7754bf1e15f55
Author: Dimitrios Liapis <di...@gmail.com>
AuthorDate: Fri May 17 23:58:11 2019 +0200
CAMEL-13209 Fixing intermittent failure by increasing the sleep time
of the main thread
---
.../org/apache/camel/component/grpc/GrpcProducerStreamingTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerStreamingTest.java b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerStreamingTest.java
index 53b2321..0a128a4 100644
--- a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerStreamingTest.java
+++ b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerStreamingTest.java
@@ -82,7 +82,7 @@ public class GrpcProducerStreamingTest extends CamelTestSupport {
template.sendBody("direct:grpc-stream-async-async-route", PingRequest.newBuilder().setPingName(String.valueOf(i)).build());
}
- template.sendBody("direct:grpc-stream-async-async-route", PingRequest.newBuilder().setPingName(String.valueOf("error")).build());
+ template.sendBody("direct:grpc-stream-async-async-route", PingRequest.newBuilder().setPingName("error").build());
@@ -90,7 +90,7 @@ public class GrpcProducerStreamingTest extends CamelTestSupport {
replies.expectedMessageCount(messageGroupCount);
replies.assertIsSatisfied();
- Thread.sleep(200);
+ Thread.sleep(1000);
for (int i = messageGroupCount + 1; i <= 2 * messageGroupCount; i++) {
template.sendBody("direct:grpc-stream-async-async-route", PingRequest.newBuilder().setPingName(String.valueOf(i)).build());