You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gn...@apache.org on 2020/03/26 08:39:52 UTC
[camel] 02/02: Fix amqp unit tests
This is an automated email from the ASF dual-hosted git repository.
gnodet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit b412d4a179a0da594daec562cd24645e9c66db68
Author: gnodet <gn...@gmail.com>
AuthorDate: Thu Mar 26 09:39:12 2020 +0100
Fix amqp unit tests
---
.../src/main/java/org/apache/camel/component/amqp/AMQPComponent.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPComponent.java b/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPComponent.java
index d2ebf9f..5269a7e 100644
--- a/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPComponent.java
+++ b/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPComponent.java
@@ -72,7 +72,7 @@ public class AMQPComponent extends JmsComponent {
// Life-cycle
@Override
- protected void doStart() throws Exception {
+ protected void doInit() throws Exception {
Set<AMQPConnectionDetails> connectionDetails = getCamelContext().getRegistry().findByType(AMQPConnectionDetails.class);
if (connectionDetails.size() == 1) {
AMQPConnectionDetails details = connectionDetails.iterator().next();
@@ -82,7 +82,7 @@ public class AMQPComponent extends JmsComponent {
}
getConfiguration().setConnectionFactory(connectionFactory);
}
- super.doStart();
+ super.doInit();
}
@Override