[camel-kafka-connector] 04/05: Polished tests timeouts.

[va...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

valdar pushed a commit to branch kamelets
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit c1c6dac7b2f78141f376bd4dfc9cccf43c0c9484
Author: Andrea Tarocchi <an...@gmail.com>
AuthorDate: Mon Jul 19 16:12:09 2021 +0200

    Polished tests timeouts.
---
 .../kafkaconnector/google/pubsub/sink/CamelSinkGooglePubSubITCase.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/itests-google-pubsub/src/test/java/org/apache/camel/kafkaconnector/google/pubsub/sink/CamelSinkGooglePubSubITCase.java b/tests/itests-google-pubsub/src/test/java/org/apache/camel/kafkaconnector/google/pubsub/sink/CamelSinkGooglePubSubITCase.java
index 12f0e19..fff41ef 100644
--- a/tests/itests-google-pubsub/src/test/java/org/apache/camel/kafkaconnector/google/pubsub/sink/CamelSinkGooglePubSubITCase.java
+++ b/tests/itests-google-pubsub/src/test/java/org/apache/camel/kafkaconnector/google/pubsub/sink/CamelSinkGooglePubSubITCase.java
@@ -92,7 +92,7 @@ public class CamelSinkGooglePubSubITCase extends CamelSinkTestSupport {
     protected void verifyMessages(CountDownLatch latch) throws InterruptedException {
         List<String> receivedMessages = easyClient.getReceivedMessages();
 
-        if (latch.await(40, TimeUnit.SECONDS)) {
+        if (latch.await(60, TimeUnit.SECONDS)) {
             assertEquals(expected, receivedMessages.size(), "Did not receive as many messages as was sent");
         } else {
             fail("Failed to receive the messages within the specified time");