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

[valdar]

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 7044f326c37f623f4ec07476f4a5dcf954450bab
Author: Andrea Tarocchi <andrea.taroc...@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");