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 cc56f5d0153474a99e64b50adcf89d74a60c3e19 Author: Dmitry Volodin <dmvo...@gmail.com> AuthorDate: Wed Jun 26 13:10:59 2019 +0300 CAMEL-13209: Fix test issue --- .../org/apache/camel/component/grpc/GrpcProducerStreamingTest.java | 4 +--- 1 file changed, 1 insertion(+), 3 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 0a128a4..8953bc4 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 @@ -84,13 +84,11 @@ public class GrpcProducerStreamingTest extends CamelTestSupport { template.sendBody("direct:grpc-stream-async-async-route", PingRequest.newBuilder().setPingName("error").build()); - - MockEndpoint replies = getMockEndpoint("mock:grpc-replies"); replies.expectedMessageCount(messageGroupCount); replies.assertIsSatisfied(); - Thread.sleep(1000); + Thread.sleep(2000); for (int i = messageGroupCount + 1; i <= 2 * messageGroupCount; i++) { template.sendBody("direct:grpc-stream-async-async-route", PingRequest.newBuilder().setPingName(String.valueOf(i)).build());