You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2019/10/07 12:37:38 UTC
[camel-quarkus] branch master updated: Throw exception out in
ActiveMQTestResource
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-quarkus.git
The following commit(s) were added to refs/heads/master by this push:
new 43e5fc9 Throw exception out in ActiveMQTestResource
new 64a4b27 Merge pull request #235 from WillemJiang/issue-234
43e5fc9 is described below
commit 43e5fc939bb32d98078781fd5b8b0d78a135a5e7
Author: Willem Jiang <wi...@gmail.com>
AuthorDate: Mon Oct 7 16:47:54 2019 +0800
Throw exception out in ActiveMQTestResource
---
.../camel/quarkus/component/paho/it/ActiveMQTestResource.java | 10 ++++++++--
1 file changed, 8 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..f64b49e 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,8 @@ public class ActiveMQTestResource implements QuarkusTestResourceLifecycleManager
broker.setDataDirectory("target");
broker.start();
} catch (Exception e) {
-
+ LOGGER.error("Starting the ActiveMQ broker with exception.", e);
+ throw new RuntimeException("Starting the ActiveMQ broker with exception.", e);
}
return Collections.emptyMap();
}
@@ -50,7 +55,8 @@ public class ActiveMQTestResource implements QuarkusTestResourceLifecycleManager
broker.stop();
}
} catch (Exception e) {
-
+ LOGGER.error("Stopping the ActiveMQ broker with exception.", e);
+ throw new RuntimeException("Stopping the ActiveMQ broker with exception.", e);
}
}
}