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:32 UTC
[camel] 09/12: CAMEL-13209: Fix test issue
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 <dm...@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());