You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2023/10/17 11:20:50 UTC
[camel] 02/06: CAMEL-19998: use the wrapper method to stop the registry
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 998c8fa41523ead5301cb2ab133e6a56a02cd6a6
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Oct 17 08:11:51 2023 +0200
CAMEL-19998: use the wrapper method to stop the registry
---
.../main/java/org/apache/camel/impl/engine/AbstractCamelContext.java | 2 +-
.../org/apache/camel/impl/engine/DefaultCamelContextExtension.java | 4 ++++
2 files changed, 5 insertions(+), 1 deletion(-)
diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java
index e730dab51da..2ab1485665c 100644
--- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java
+++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java
@@ -2879,7 +2879,7 @@ public abstract class AbstractCamelContext extends BaseService
// shutdown type converter and registry as late as possible
camelContextExtension.stopTypeConverter();
camelContextExtension.stopTypeConverterRegistry();
- ServiceHelper.stopService(camelContextExtension.getRegistry());
+ camelContextExtension.stopRegistry();
// stop the lazy created so they can be re-created on restart
forceStopLazyInitialization();
diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultCamelContextExtension.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultCamelContextExtension.java
index 7c157f921de..d3a0bc2cfc0 100644
--- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultCamelContextExtension.java
+++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultCamelContextExtension.java
@@ -334,6 +334,10 @@ class DefaultCamelContextExtension implements ExtendedCamelContext {
this.managementMBeanAssembler = camelContext.getInternalServiceManager().addService(managementMBeanAssembler, false);
}
+ void stopRegistry() {
+ ServiceHelper.stopService(registry);
+ }
+
@Override
public Registry getRegistry() {
if (registry == null) {