You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2019/10/07 08:48:14 UTC

[camel-quarkus] 01/01: #234 Added log when starting or stoping ActiveMQ Broker failed

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

ningjiang pushed a commit to branch issue-234
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git

commit bcfe5d65825353e03648db7f0d70d39bb37b6ede
Author: Willem Jiang <wi...@gmail.com>
AuthorDate: Mon Oct 7 16:47:54 2019 +0800

    #234 Added log when starting or stoping ActiveMQ Broker failed
---
 .../camel/quarkus/component/paho/it/ActiveMQTestResource.java     | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/integration-tests/paho/src/test/java/org/apache/camel/quarkus/component/paho/it/ActiveMQTestResource.java b/integration-tests/paho/src/test/java/org/apache/camel/quarkus/component/paho/it/ActiveMQTestResource.java
index 7c1a6a8..e656ad5 100644
--- a/integration-tests/paho/src/test/java/org/apache/camel/quarkus/component/paho/it/ActiveMQTestResource.java
+++ b/integration-tests/paho/src/test/java/org/apache/camel/quarkus/component/paho/it/ActiveMQTestResource.java
@@ -24,10 +24,14 @@ import java.util.Map;
 import io.quarkus.test.common.QuarkusTestResourceLifecycleManager;
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.TransportConnector;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class ActiveMQTestResource implements QuarkusTestResourceLifecycleManager {
+    private final static Logger LOGGER = LoggerFactory.getLogger(ActiveMQTestResource.class);
     private BrokerService broker;
 
+
     @Override
     public Map<String, String> start() {
         try {
@@ -38,7 +42,7 @@ public class ActiveMQTestResource implements QuarkusTestResourceLifecycleManager
             broker.setDataDirectory("target");
             broker.start();
         } catch (Exception e) {
-
+            LOGGER.error("Starting the ActiveMQ broker with exception.", e);
         }
         return Collections.emptyMap();
     }
@@ -50,7 +54,7 @@ public class ActiveMQTestResource implements QuarkusTestResourceLifecycleManager
                 broker.stop();
             }
         } catch (Exception e) {
-
+            LOGGER.error("Stopping the ActiveMQ broker with exception.", e);
         }
     }
 }