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());

Reply via email to