[camel] 01/02: Camel-NSQ: Wait for message in logs for the container initialization in tests

[acosentino]

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

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit d5b64b111acc4666a1a9976cb3b7c03485f12893
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Thu Jul 4 08:23:57 2019 +0200

    Camel-NSQ: Wait for message in logs for  the container initialization in 
tests
---
 .../src/test/java/org/apache/camel/component/nsq/NsqTestSupport.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqTestSupport.java
 
b/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqTestSupport.java
index 5271c63..1c2bff6 100644
--- 
a/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqTestSupport.java
+++ 
b/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqTestSupport.java
@@ -21,6 +21,7 @@ import java.util.Arrays;
 import java.util.List;
 
 import org.apache.camel.test.testcontainers.ContainerAwareTestSupport;
+import org.apache.camel.test.testcontainers.Wait;
 import org.testcontainers.containers.FixedHostPortGenericContainer;
 import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.containers.Network;
@@ -43,12 +44,12 @@ public class NsqTestSupport extends 
ContainerAwareTestSupport {
 
     public static GenericContainer<?> nsqlookupdContainer(Network network) {
         return new 
FixedHostPortGenericContainer<>(CONTAINER_NSQLOOKUPD_IMAGE).withFixedExposedPort(4160,
 4160).withFixedExposedPort(4161, 4161)
-            
.withNetworkAliases(CONTAINER_NSQLOOKUPD_NAME).withCommand("/nsqlookupd").withNetwork(network);
+            
.withNetworkAliases(CONTAINER_NSQLOOKUPD_NAME).withCommand("/nsqlookupd").withNetwork(network).waitingFor(Wait.forLogMessageContaining("TCP:
 listening on", 1));
     }
 
     public static GenericContainer<?> nsqdContainer(Network network) {
         return new 
FixedHostPortGenericContainer<>(CONTAINER_NSQD_IMAGE).withFixedExposedPort(4150,
 4150).withFixedExposedPort(4151, 4151).withNetworkAliases(CONTAINER_NSQD_NAME)
-            .withCommand(String.format("/nsqd --broadcast-address=%s 
--lookupd-tcp-address=%s:4160", "localhost", 
CONTAINER_NSQLOOKUPD_NAME)).withNetwork(network);
+            .withCommand(String.format("/nsqd --broadcast-address=%s 
--lookupd-tcp-address=%s:4160", "localhost", 
CONTAINER_NSQLOOKUPD_NAME)).withNetwork(network).waitingFor(Wait.forLogMessageContaining("TCP:
 listening on", 1));
     }
 
     public String getNsqConsumerUrl() {