[camel-kafka-connector] 02/02: Do initialize the container at the correct callback

[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-kafka-connector.git

commit e85aa5c6eadcf934093ab855e99bef4a1e7ec2c6
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Thu Nov 5 15:21:39 2020 +0100

    Do initialize the container at the correct callback
---
 .../camel/kafkaconnector/sjms2/services/ContainerLocalService.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/services/ContainerLocalService.java
 
b/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/services/ContainerLocalService.java
index 9e2264f..9929f41 100644
--- 
a/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/services/ContainerLocalService.java
+++ 
b/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/services/ContainerLocalService.java
@@ -33,8 +33,6 @@ public class ContainerLocalService implements JMSService {
 
     public ContainerLocalService(JMSContainer container) {
         this.container = container;
-
-        container.start();
     }
 
     @Override
@@ -49,6 +47,8 @@ public class ContainerLocalService implements JMSService {
 
     @Override
     public void initialize() {
+        LOG.info("Trying to start the JMS broker container");
+        container.start();
         LOG.info("JMS broker running at address {}", 
container.getDefaultEndpoint());
     }