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 <dimitri...@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());