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/02/25 16:08:49 UTC
[camel] branch main updated (eb9840bb49b -> 813cbb7c7eb)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from eb9840bb49b Regen for commit cb4cfd930cfd75e287d803518b4954001424a90e
new fe2ee35a4b1 CAMEL-19086: split the ExtendedCamelContext from the Context for the LightweightCamelContext
new 813cbb7c7eb CAMEL-19086: split the ExtendedCamelContext from the Context for the LightweightRuntimeCamelContext
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../camel/impl/lw/LightweightCamelContext.java | 699 +-----------
.../impl/lw/LightweightCamelContextExtension.java | 969 ++++++++++++++++
.../impl/lw/LightweightRuntimeCamelContext.java | 1203 ++------------------
.../java/org/apache/camel/ContextTestSupport.java | 3 +-
4 files changed, 1091 insertions(+), 1783 deletions(-)
create mode 100644 core/camel-core-engine/src/main/java/org/apache/camel/impl/lw/LightweightCamelContextExtension.java
[camel] 02/02: CAMEL-19086: split the ExtendedCamelContext from the Context for the LightweightRuntimeCamelContext
Posted by or...@apache.org.
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 813cbb7c7eb3a8b085ebd8065f9bbe97298c7d38
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu Feb 23 15:59:58 2023 +0100
CAMEL-19086: split the ExtendedCamelContext from the Context for the LightweightRuntimeCamelContext
---
.../impl/lw/LightweightCamelContextExtension.java | 969 ++++++++++++++++
.../impl/lw/LightweightRuntimeCamelContext.java | 1203 ++------------------
2 files changed, 1088 insertions(+), 1084 deletions(-)
diff --git a/core/camel-core-engine/src/main/java/org/apache/camel/impl/lw/LightweightCamelContextExtension.java b/core/camel-core-engine/src/main/java/org/apache/camel/impl/lw/LightweightCamelContextExtension.java
new file mode 100644
index 00000000000..25ed86d82da
--- /dev/null
+++ b/core/camel-core-engine/src/main/java/org/apache/camel/impl/lw/LightweightCamelContextExtension.java
@@ -0,0 +1,969 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.camel.impl.lw;
+
+import java.util.Collection;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.Endpoint;
+import org.apache.camel.ErrorHandlerFactory;
+import org.apache.camel.ExchangeConstantProvider;
+import org.apache.camel.ExtendedCamelContext;
+import org.apache.camel.LoggingLevel;
+import org.apache.camel.NoSuchEndpointException;
+import org.apache.camel.Processor;
+import org.apache.camel.ResolveEndpointFailedException;
+import org.apache.camel.Route;
+import org.apache.camel.Service;
+import org.apache.camel.ServiceStatus;
+import org.apache.camel.catalog.RuntimeCamelCatalog;
+import org.apache.camel.console.DevConsoleResolver;
+import org.apache.camel.health.HealthCheckResolver;
+import org.apache.camel.spi.AnnotationBasedProcessorFactory;
+import org.apache.camel.spi.AsyncProcessorAwaitManager;
+import org.apache.camel.spi.BeanIntrospection;
+import org.apache.camel.spi.BeanProcessorFactory;
+import org.apache.camel.spi.BeanProxyFactory;
+import org.apache.camel.spi.BootstrapCloseable;
+import org.apache.camel.spi.CamelBeanPostProcessor;
+import org.apache.camel.spi.CamelDependencyInjectionAnnotationFactory;
+import org.apache.camel.spi.CliConnectorFactory;
+import org.apache.camel.spi.ComponentNameResolver;
+import org.apache.camel.spi.ComponentResolver;
+import org.apache.camel.spi.ConfigurerResolver;
+import org.apache.camel.spi.DataFormatResolver;
+import org.apache.camel.spi.DeferServiceFactory;
+import org.apache.camel.spi.EndpointStrategy;
+import org.apache.camel.spi.EndpointUriFactory;
+import org.apache.camel.spi.ExchangeFactory;
+import org.apache.camel.spi.ExchangeFactoryManager;
+import org.apache.camel.spi.FactoryFinder;
+import org.apache.camel.spi.FactoryFinderResolver;
+import org.apache.camel.spi.HeadersMapFactory;
+import org.apache.camel.spi.InterceptEndpointFactory;
+import org.apache.camel.spi.InterceptStrategy;
+import org.apache.camel.spi.InternalProcessorFactory;
+import org.apache.camel.spi.LanguageResolver;
+import org.apache.camel.spi.LogListener;
+import org.apache.camel.spi.ManagementMBeanAssembler;
+import org.apache.camel.spi.ModelJAXBContextFactory;
+import org.apache.camel.spi.ModelToXMLDumper;
+import org.apache.camel.spi.ModelineFactory;
+import org.apache.camel.spi.NodeIdFactory;
+import org.apache.camel.spi.NormalizedEndpointUri;
+import org.apache.camel.spi.PackageScanClassResolver;
+import org.apache.camel.spi.PackageScanResourceResolver;
+import org.apache.camel.spi.PeriodTaskResolver;
+import org.apache.camel.spi.PeriodTaskScheduler;
+import org.apache.camel.spi.ProcessorExchangeFactory;
+import org.apache.camel.spi.ProcessorFactory;
+import org.apache.camel.spi.PropertiesComponent;
+import org.apache.camel.spi.ReactiveExecutor;
+import org.apache.camel.spi.Registry;
+import org.apache.camel.spi.ResourceLoader;
+import org.apache.camel.spi.RestBindingJaxbDataFormatFactory;
+import org.apache.camel.spi.RouteController;
+import org.apache.camel.spi.RouteFactory;
+import org.apache.camel.spi.RouteStartupOrder;
+import org.apache.camel.spi.RoutesLoader;
+import org.apache.camel.spi.StartupStepRecorder;
+import org.apache.camel.spi.SupervisingRouteController;
+import org.apache.camel.spi.UnitOfWorkFactory;
+import org.apache.camel.spi.UriFactoryResolver;
+import org.apache.camel.support.NormalizedUri;
+import org.apache.camel.util.StringHelper;
+import org.apache.camel.util.URISupport;
+
+class LightweightCamelContextExtension implements ExtendedCamelContext {
+ private final CamelContext camelContext;
+
+ public LightweightCamelContextExtension(CamelContext camelContext) {
+ this.camelContext = camelContext;
+ }
+
+ @Override
+ public byte getStatusPhase() {
+ return camelContext.getCamelContextExtension().getStatusPhase();
+ }
+
+ @Override
+ public void disposeModel() {
+ // noop
+ }
+
+ @Override
+ public Registry getRegistry() {
+ return camelContext.getCamelContextExtension().getRegistry();
+ }
+
+ @Override
+ public void setRegistry(Registry registry) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ModelJAXBContextFactory getModelJAXBContextFactory() {
+ return camelContext.getCamelContextExtension().getModelJAXBContextFactory();
+ }
+
+ @Override
+ public void setModelJAXBContextFactory(ModelJAXBContextFactory modelJAXBContextFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ComponentResolver getComponentResolver() {
+ return camelContext.getCamelContextExtension().getComponentResolver();
+ }
+
+ @Override
+ public void setComponentResolver(ComponentResolver componentResolver) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ComponentNameResolver getComponentNameResolver() {
+ return camelContext.getCamelContextExtension().getComponentNameResolver();
+ }
+
+ @Override
+ public void setComponentNameResolver(ComponentNameResolver componentResolver) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public LanguageResolver getLanguageResolver() {
+ return camelContext.getCamelContextExtension().getLanguageResolver();
+ }
+
+ @Override
+ public void setLanguageResolver(LanguageResolver languageResolver) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public DataFormatResolver getDataFormatResolver() {
+ return camelContext.getCamelContextExtension().getDataFormatResolver();
+ }
+
+ @Override
+ public void setDataFormatResolver(DataFormatResolver dataFormatResolver) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public HealthCheckResolver getHealthCheckResolver() {
+ return camelContext.getCamelContextExtension().getHealthCheckResolver();
+ }
+
+ @Override
+ public void setHealthCheckResolver(HealthCheckResolver healthCheckResolver) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public DevConsoleResolver getDevConsoleResolver() {
+ return camelContext.getCamelContextExtension().getDevConsoleResolver();
+ }
+
+ @Override
+ public void setDevConsoleResolver(DevConsoleResolver devConsoleResolver) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public String getName() {
+ return camelContext.getCamelContextExtension().getName();
+ }
+
+ @Override
+ public void setName(String name) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public String getDescription() {
+ return camelContext.getCamelContextExtension().getDescription();
+ }
+
+ @Override
+ public void setDescription(String description) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void addBootstrap(BootstrapCloseable bootstrap) {
+ }
+
+ @Override
+ public List<Service> getServices() {
+ return null;
+ }
+
+ @Override
+ public String resolvePropertyPlaceholders(String text, boolean keepUnresolvedOptional) {
+ if (text != null && text.contains(PropertiesComponent.PREFIX_TOKEN)) {
+ // the parser will throw exception if property key was not found
+ return camelContext.getPropertiesComponent().parseUri(text, keepUnresolvedOptional);
+ }
+ // is the value a known field (currently we only support
+ // constants from Exchange.class)
+ if (text != null && text.startsWith("Exchange.")) {
+ String field = StringHelper.after(text, "Exchange.");
+ String constant = ExchangeConstantProvider.lookup(field);
+ if (constant != null) {
+ return constant;
+ } else {
+ throw new IllegalArgumentException("Constant field with name: " + field + " not found on Exchange.class");
+ }
+ }
+ // return original text as is
+ return text;
+ }
+
+ @Override
+ public String getBasePackageScan() {
+ return camelContext.getCamelContextExtension().getBasePackageScan();
+ }
+
+ @Override
+ public void setBasePackageScan(String basePackageScan) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public Endpoint getPrototypeEndpoint(String uri) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public Endpoint getPrototypeEndpoint(NormalizedEndpointUri uri) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public Endpoint hasEndpoint(NormalizedEndpointUri uri) {
+ return camelContext.getEndpointRegistry().get(uri);
+ }
+
+ @Override
+ public Endpoint getEndpoint(NormalizedEndpointUri uri) {
+ return doGetEndpoint(uri.getUri(), true, false);
+ }
+
+ @Override
+ public Endpoint getEndpoint(NormalizedEndpointUri uri, Map<String, Object> parameters) {
+ return doGetEndpoint(uri.getUri(), parameters, true);
+ }
+
+ @Override
+ public NormalizedEndpointUri normalizeUri(String uri) {
+ try {
+ uri = resolvePropertyPlaceholders(uri, false);
+ return NormalizedUri.newNormalizedUri(uri, false);
+ } catch (Exception e) {
+ throw new ResolveEndpointFailedException(uri, e);
+ }
+ }
+
+ @Override
+ public List<RouteStartupOrder> getRouteStartupOrder() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public CamelBeanPostProcessor getBeanPostProcessor() {
+ return camelContext.getCamelContextExtension().getBeanPostProcessor();
+ }
+
+ @Override
+ public void setBeanPostProcessor(CamelBeanPostProcessor beanPostProcessor) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public CamelDependencyInjectionAnnotationFactory getDependencyInjectionAnnotationFactory() {
+ return camelContext.getCamelContextExtension().getDependencyInjectionAnnotationFactory();
+ }
+
+ @Override
+ public void setDependencyInjectionAnnotationFactory(CamelDependencyInjectionAnnotationFactory factory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ManagementMBeanAssembler getManagementMBeanAssembler() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ErrorHandlerFactory getErrorHandlerFactory() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setErrorHandlerFactory(ErrorHandlerFactory errorHandlerFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public PackageScanClassResolver getPackageScanClassResolver() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setPackageScanClassResolver(PackageScanClassResolver resolver) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public PackageScanResourceResolver getPackageScanResourceResolver() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setPackageScanResourceResolver(PackageScanResourceResolver resolver) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public FactoryFinder getDefaultFactoryFinder() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ConfigurerResolver getBootstrapConfigurerResolver() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setBootstrapConfigurerResolver(ConfigurerResolver configurerResolver) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public FactoryFinder getBootstrapFactoryFinder() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setBootstrapFactoryFinder(FactoryFinder factoryFinder) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public FactoryFinder getBootstrapFactoryFinder(String path) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public FactoryFinder getFactoryFinder(String path) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public FactoryFinderResolver getFactoryFinderResolver() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setFactoryFinderResolver(FactoryFinderResolver resolver) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ProcessorFactory getProcessorFactory() {
+ return camelContext.getCamelContextExtension().getProcessorFactory();
+ }
+
+ @Override
+ public void setProcessorFactory(ProcessorFactory processorFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ModelineFactory getModelineFactory() {
+ return camelContext.getCamelContextExtension().getModelineFactory();
+ }
+
+ @Override
+ public void setModelineFactory(ModelineFactory modelineFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public InternalProcessorFactory getInternalProcessorFactory() {
+ return camelContext.getCamelContextExtension().getInternalProcessorFactory();
+ }
+
+ @Override
+ public void setInternalProcessorFactory(InternalProcessorFactory internalProcessorFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public InterceptEndpointFactory getInterceptEndpointFactory() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setInterceptEndpointFactory(InterceptEndpointFactory interceptEndpointFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public RouteFactory getRouteFactory() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setRouteFactory(RouteFactory routeFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public DeferServiceFactory getDeferServiceFactory() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setDeferServiceFactory(DeferServiceFactory deferServiceFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public UnitOfWorkFactory getUnitOfWorkFactory() {
+ return camelContext.getCamelContextExtension().getUnitOfWorkFactory();
+ }
+
+ @Override
+ public void setUnitOfWorkFactory(UnitOfWorkFactory unitOfWorkFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public AnnotationBasedProcessorFactory getAnnotationBasedProcessorFactory() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setAnnotationBasedProcessorFactory(AnnotationBasedProcessorFactory annotationBasedProcessorFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public BeanProxyFactory getBeanProxyFactory() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public BeanProcessorFactory getBeanProcessorFactory() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ScheduledExecutorService getErrorHandlerExecutorService() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public List<InterceptStrategy> getInterceptStrategies() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public Set<LogListener> getLogListeners() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public AsyncProcessorAwaitManager getAsyncProcessorAwaitManager() {
+ return camelContext.getCamelContextExtension().getAsyncProcessorAwaitManager();
+ }
+
+ @Override
+ public void setAsyncProcessorAwaitManager(AsyncProcessorAwaitManager manager) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public BeanIntrospection getBeanIntrospection() {
+ return camelContext.getCamelContextExtension().getBeanIntrospection();
+ }
+
+ @Override
+ public void setBeanIntrospection(BeanIntrospection beanIntrospection) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public HeadersMapFactory getHeadersMapFactory() {
+ return camelContext.getCamelContextExtension().getHeadersMapFactory();
+ }
+
+ @Override
+ public void setHeadersMapFactory(HeadersMapFactory factory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public CliConnectorFactory getCliConnectorFactory() {
+ return camelContext.getCamelContextExtension().getCliConnectorFactory();
+ }
+
+ @Override
+ public void setCliConnectorFactory(CliConnectorFactory cliConnectorFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ExchangeFactory getExchangeFactory() {
+ return camelContext.getCamelContextExtension().getExchangeFactory();
+ }
+
+ @Override
+ public ExchangeFactoryManager getExchangeFactoryManager() {
+ return camelContext.getCamelContextExtension().getExchangeFactoryManager();
+ }
+
+ @Override
+ public void setExchangeFactoryManager(ExchangeFactoryManager exchangeFactoryManager) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setExchangeFactory(ExchangeFactory exchangeFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ProcessorExchangeFactory getProcessorExchangeFactory() {
+ return camelContext.getCamelContextExtension().getProcessorExchangeFactory();
+ }
+
+ @Override
+ public void setProcessorExchangeFactory(ProcessorExchangeFactory processorExchangeFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ReactiveExecutor getReactiveExecutor() {
+ return camelContext.getCamelContextExtension().getReactiveExecutor();
+ }
+
+ @Override
+ public void setReactiveExecutor(ReactiveExecutor reactiveExecutor) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public boolean isEventNotificationApplicable() {
+ return camelContext.getCamelContextExtension().isEventNotificationApplicable();
+ }
+
+ @Override
+ public void setEventNotificationApplicable(boolean eventNotificationApplicable) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ModelToXMLDumper getModelToXMLDumper() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setModelToXMLDumper(ModelToXMLDumper modelToXMLDumper) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public RuntimeCamelCatalog getRuntimeCamelCatalog() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setRuntimeCamelCatalog(RuntimeCamelCatalog runtimeCamelCatalog) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ConfigurerResolver getConfigurerResolver() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setConfigurerResolver(ConfigurerResolver configurerResolver) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void addRoute(Route route) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void removeRoute(Route route) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public Processor createErrorHandler(Route route, Processor processor) throws Exception {
+ // TODO: need to revisit this in order to support dynamic endpoints uri
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setupRoutes(boolean done) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public boolean isSetupRoutes() {
+ return false;
+ }
+
+ @Override
+ public void addInterceptStrategy(InterceptStrategy interceptStrategy) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setupManagement(Map<String, Object> options) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void addLogListener(LogListener listener) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public RestBindingJaxbDataFormatFactory getRestBindingJaxbDataFormatFactory() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setRestBindingJaxbDataFormatFactory(RestBindingJaxbDataFormatFactory restBindingJaxbDataFormatFactory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setRoutesLoader(RoutesLoader routesLoader) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public RoutesLoader getRoutesLoader() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public ResourceLoader getResourceLoader() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setResourceLoader(ResourceLoader resourceLoader) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void registerEndpointCallback(EndpointStrategy strategy) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public NodeIdFactory getNodeIdFactory() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setNodeIdFactory(NodeIdFactory factory) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setLightweight(boolean lightweight) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public boolean isLightweight() {
+ return true;
+ }
+
+ @Override
+ public String getTestExcludeRoutes() {
+ return null;
+ }
+
+ @Override
+ public RouteController getInternalRouteController() {
+ return new RouteController() {
+ @Override
+ public LoggingLevel getLoggingLevel() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setLoggingLevel(LoggingLevel loggingLevel) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public boolean isSupervising() {
+ return false;
+ }
+
+ @Override
+ public SupervisingRouteController supervising() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public <T extends RouteController> T adapt(Class<T> type) {
+ return type.cast(this);
+ }
+
+ @Override
+ public Collection<Route> getControlledRoutes() {
+ return camelContext.getRoutes();
+ }
+
+ @Override
+ public void startAllRoutes() throws Exception {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void stopAllRoutes() throws Exception {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void removeAllRoutes() throws Exception {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public boolean isStartingRoutes() {
+ return false;
+ }
+
+ @Override
+ public void reloadAllRoutes() throws Exception {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public boolean isReloadingRoutes() {
+ return false;
+ }
+
+ @Override
+ public ServiceStatus getRouteStatus(String routeId) {
+ return ServiceStatus.Started;
+ }
+
+ @Override
+ public void startRoute(String routeId) throws Exception {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void stopRoute(String routeId) throws Exception {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void stopRoute(String routeId, Throwable cause) throws Exception {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void stopRoute(String routeId, long timeout, TimeUnit timeUnit) throws Exception {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public boolean stopRoute(String routeId, long timeout, TimeUnit timeUnit, boolean abortAfterTimeout)
+ throws Exception {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void suspendRoute(String routeId) throws Exception {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void suspendRoute(String routeId, long timeout, TimeUnit timeUnit) throws Exception {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void resumeRoute(String routeId) throws Exception {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public CamelContext getCamelContext() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setCamelContext(CamelContext camelContext) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void start() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void stop() {
+ throw new UnsupportedOperationException();
+ }
+ };
+ }
+
+ @Override
+ public UriFactoryResolver getUriFactoryResolver() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setUriFactoryResolver(UriFactoryResolver uriFactoryResolver) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public EndpointUriFactory getEndpointUriFactory(String scheme) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public StartupStepRecorder getStartupStepRecorder() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void setStartupStepRecorder(StartupStepRecorder startupStepRecorder) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public PeriodTaskResolver getPeriodTaskResolver() {
+ return camelContext.getCamelContextExtension().getPeriodTaskResolver();
+ }
+
+ @Override
+ public void setPeriodTaskScheduler(PeriodTaskScheduler periodTaskScheduler) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public PeriodTaskScheduler getPeriodTaskScheduler() {
+ return camelContext.getCamelContextExtension().getPeriodTaskScheduler();
+ }
+
+ @Override
+ public void setPeriodTaskResolver(PeriodTaskResolver periodTaskResolver) {
+ throw new UnsupportedOperationException();
+ }
+
+ Endpoint doGetEndpoint(String uri, boolean normalized, boolean prototype) {
+ StringHelper.notEmpty(uri, "uri");
+ // in case path has property placeholders then try to let property
+ // component resolve those
+ if (!normalized) {
+ try {
+ uri = camelContext.getCamelContextExtension().resolvePropertyPlaceholders(uri, false);
+ } catch (Exception e) {
+ throw new ResolveEndpointFailedException(uri, e);
+ }
+ }
+ // normalize uri so we can do endpoint hits with minor mistakes and
+ // parameters is not in the same order
+ if (!normalized) {
+ uri = normalizeEndpointUri(uri);
+ }
+ Endpoint answer = null;
+ if (!prototype) {
+ // use optimized method to get the endpoint uri
+ NormalizedUri key = NormalizedUri.newNormalizedUri(uri, true);
+ // only lookup and reuse existing endpoints if not prototype scoped
+ answer = camelContext.getEndpointRegistry().get(key);
+ }
+ // unknown scheme
+ if (answer == null) {
+ throw new NoSuchEndpointException(uri);
+ }
+ return answer;
+ }
+
+ protected Endpoint doGetEndpoint(String uri, Map<String, Object> parameters, boolean normalized) {
+ StringHelper.notEmpty(uri, "uri");
+ // in case path has property placeholders then try to let property
+ // component resolve those
+ if (!normalized) {
+ try {
+ uri = resolvePropertyPlaceholders(uri, false);
+ } catch (Exception e) {
+ throw new ResolveEndpointFailedException(uri, e);
+ }
+ }
+ // normalize uri so we can do endpoint hits with minor mistakes and
+ // parameters is not in the same order
+ if (!normalized) {
+ uri = normalizeEndpointUri(uri);
+ }
+ Endpoint answer;
+ String scheme = null;
+ // use optimized method to get the endpoint uri
+ NormalizedUri key = NormalizedUri.newNormalizedUri(uri, true);
+ answer = camelContext.getEndpointRegistry().get(key);
+ // unknown scheme
+ if (answer == null) {
+ throw new ResolveEndpointFailedException(uri, "No component found with scheme: " + scheme);
+ }
+ return answer;
+ }
+
+ /**
+ * Normalize uri so we can do endpoint hits with minor mistakes and parameters is not in the same order.
+ *
+ * @param uri the uri
+ * @return normalized uri
+ * @throws ResolveEndpointFailedException if uri cannot be normalized
+ */
+ static String normalizeEndpointUri(String uri) {
+ try {
+ uri = URISupport.normalizeUri(uri);
+ } catch (Exception e) {
+ throw new ResolveEndpointFailedException(uri, e);
+ }
+ return uri;
+ }
+}
diff --git a/core/camel-core-engine/src/main/java/org/apache/camel/impl/lw/LightweightRuntimeCamelContext.java b/core/camel-core-engine/src/main/java/org/apache/camel/impl/lw/LightweightRuntimeCamelContext.java
index 507ae20682f..cdcfe01800b 100644
--- a/core/camel-core-engine/src/main/java/org/apache/camel/impl/lw/LightweightRuntimeCamelContext.java
+++ b/core/camel-core-engine/src/main/java/org/apache/camel/impl/lw/LightweightRuntimeCamelContext.java
@@ -25,8 +25,6 @@ import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.Set;
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import org.apache.camel.CamelContext;
@@ -35,19 +33,15 @@ import org.apache.camel.CatalogCamelContext;
import org.apache.camel.Component;
import org.apache.camel.ConsumerTemplate;
import org.apache.camel.Endpoint;
-import org.apache.camel.ErrorHandlerFactory;
-import org.apache.camel.ExchangeConstantProvider;
import org.apache.camel.Experimental;
import org.apache.camel.ExtendedCamelContext;
import org.apache.camel.FluentProducerTemplate;
import org.apache.camel.GlobalEndpointConfiguration;
import org.apache.camel.IsSingleton;
-import org.apache.camel.LoggingLevel;
import org.apache.camel.NoSuchEndpointException;
import org.apache.camel.NoSuchLanguageException;
import org.apache.camel.Processor;
import org.apache.camel.ProducerTemplate;
-import org.apache.camel.ResolveEndpointFailedException;
import org.apache.camel.Route;
import org.apache.camel.RouteConfigurationsBuilder;
import org.apache.camel.RouteTemplateContext;
@@ -61,89 +55,38 @@ import org.apache.camel.StartupListener;
import org.apache.camel.StartupSummaryLevel;
import org.apache.camel.TypeConverter;
import org.apache.camel.ValueHolder;
-import org.apache.camel.catalog.RuntimeCamelCatalog;
-import org.apache.camel.console.DevConsoleResolver;
-import org.apache.camel.health.HealthCheckResolver;
import org.apache.camel.impl.converter.CoreTypeConverterRegistry;
import org.apache.camel.impl.engine.DefaultComponentResolver;
import org.apache.camel.impl.engine.DefaultDataFormatResolver;
import org.apache.camel.impl.engine.DefaultLanguageResolver;
-import org.apache.camel.spi.AnnotationBasedProcessorFactory;
-import org.apache.camel.spi.AsyncProcessorAwaitManager;
-import org.apache.camel.spi.BeanIntrospection;
-import org.apache.camel.spi.BeanProcessorFactory;
-import org.apache.camel.spi.BeanProxyFactory;
-import org.apache.camel.spi.BootstrapCloseable;
-import org.apache.camel.spi.CamelBeanPostProcessor;
import org.apache.camel.spi.CamelContextNameStrategy;
-import org.apache.camel.spi.CamelDependencyInjectionAnnotationFactory;
import org.apache.camel.spi.ClassResolver;
-import org.apache.camel.spi.CliConnectorFactory;
-import org.apache.camel.spi.ComponentNameResolver;
-import org.apache.camel.spi.ComponentResolver;
-import org.apache.camel.spi.ConfigurerResolver;
import org.apache.camel.spi.DataFormat;
-import org.apache.camel.spi.DataFormatResolver;
import org.apache.camel.spi.DataType;
import org.apache.camel.spi.Debugger;
-import org.apache.camel.spi.DeferServiceFactory;
import org.apache.camel.spi.EndpointRegistry;
-import org.apache.camel.spi.EndpointStrategy;
-import org.apache.camel.spi.EndpointUriFactory;
-import org.apache.camel.spi.ExchangeFactory;
-import org.apache.camel.spi.ExchangeFactoryManager;
import org.apache.camel.spi.ExecutorServiceManager;
-import org.apache.camel.spi.FactoryFinder;
-import org.apache.camel.spi.FactoryFinderResolver;
-import org.apache.camel.spi.HeadersMapFactory;
import org.apache.camel.spi.InflightRepository;
import org.apache.camel.spi.Injector;
-import org.apache.camel.spi.InterceptEndpointFactory;
import org.apache.camel.spi.InterceptSendToEndpoint;
-import org.apache.camel.spi.InterceptStrategy;
-import org.apache.camel.spi.InternalProcessorFactory;
import org.apache.camel.spi.Language;
-import org.apache.camel.spi.LanguageResolver;
import org.apache.camel.spi.LifecycleStrategy;
-import org.apache.camel.spi.LogListener;
-import org.apache.camel.spi.ManagementMBeanAssembler;
import org.apache.camel.spi.ManagementNameStrategy;
import org.apache.camel.spi.ManagementStrategy;
import org.apache.camel.spi.MessageHistoryFactory;
-import org.apache.camel.spi.ModelJAXBContextFactory;
-import org.apache.camel.spi.ModelToXMLDumper;
-import org.apache.camel.spi.ModelineFactory;
-import org.apache.camel.spi.NodeIdFactory;
-import org.apache.camel.spi.NormalizedEndpointUri;
-import org.apache.camel.spi.PackageScanClassResolver;
-import org.apache.camel.spi.PackageScanResourceResolver;
-import org.apache.camel.spi.PeriodTaskResolver;
-import org.apache.camel.spi.PeriodTaskScheduler;
-import org.apache.camel.spi.ProcessorExchangeFactory;
-import org.apache.camel.spi.ProcessorFactory;
import org.apache.camel.spi.PropertiesComponent;
-import org.apache.camel.spi.ReactiveExecutor;
import org.apache.camel.spi.Registry;
-import org.apache.camel.spi.ResourceLoader;
-import org.apache.camel.spi.RestBindingJaxbDataFormatFactory;
import org.apache.camel.spi.RestConfiguration;
import org.apache.camel.spi.RestRegistry;
import org.apache.camel.spi.RouteController;
-import org.apache.camel.spi.RouteFactory;
import org.apache.camel.spi.RoutePolicyFactory;
-import org.apache.camel.spi.RouteStartupOrder;
-import org.apache.camel.spi.RoutesLoader;
import org.apache.camel.spi.RuntimeEndpointRegistry;
import org.apache.camel.spi.ShutdownStrategy;
-import org.apache.camel.spi.StartupStepRecorder;
import org.apache.camel.spi.StreamCachingStrategy;
-import org.apache.camel.spi.SupervisingRouteController;
import org.apache.camel.spi.Tracer;
import org.apache.camel.spi.Transformer;
import org.apache.camel.spi.TransformerRegistry;
import org.apache.camel.spi.TypeConverterRegistry;
-import org.apache.camel.spi.UnitOfWorkFactory;
-import org.apache.camel.spi.UriFactoryResolver;
import org.apache.camel.spi.UuidGenerator;
import org.apache.camel.spi.Validator;
import org.apache.camel.spi.ValidatorRegistry;
@@ -152,71 +95,44 @@ import org.apache.camel.support.NormalizedUri;
import org.apache.camel.support.jsse.SSLContextParameters;
import org.apache.camel.util.IOHelper;
import org.apache.camel.util.ObjectHelper;
-import org.apache.camel.util.StringHelper;
import org.apache.camel.util.TimeUtils;
-import org.apache.camel.util.URISupport;
import org.apache.camel.vault.VaultConfiguration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@Experimental
-public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCamelContext, CatalogCamelContext {
+public class LightweightRuntimeCamelContext implements CamelContext, CatalogCamelContext {
private static final Logger LOG = LoggerFactory.getLogger(LightweightRuntimeCamelContext.class);
private final CamelContext reference;
private final Registry registry;
private final CoreTypeConverterRegistry typeConverter;
- private final ModelJAXBContextFactory modelJAXBContextFactory;
- private final ComponentResolver componentResolver;
- private final ComponentNameResolver componentNameResolver;
- private final LanguageResolver languageResolver;
- private final DataFormatResolver dataFormatResolver;
- private final HealthCheckResolver healthCheckResolver;
- private final DevConsoleResolver devConsoleResolver;
private final UuidGenerator uuidGenerator;
private final EndpointRegistry<? extends ValueHolder<String>> endpoints;
private final Map<String, Component> components;
private final Map<String, Language> languages;
private final PropertiesComponent propertiesComponent;
- private final BeanIntrospection beanIntrospection;
- private final CamelBeanPostProcessor beanPostProcessor;
- private final CamelDependencyInjectionAnnotationFactory dependencyInjectionAnnotationFactory;
- private final HeadersMapFactory headersMapFactory;
- private final CliConnectorFactory cliConnectorFactory;
- private final ExchangeFactory exchangeFactory;
- private final ExchangeFactoryManager exchangeFactoryManager;
- private final ProcessorExchangeFactory processorExchangeFactory;
- private final ModelineFactory modelineFactory;
- private final ReactiveExecutor reactiveExecutor;
- private final AsyncProcessorAwaitManager asyncProcessorAwaitManager;
private final ExecutorServiceManager executorServiceManager;
private final ShutdownStrategy shutdownStrategy;
private final ClassLoader applicationContextClassLoader;
- private final UnitOfWorkFactory unitOfWorkFactory;
private final RouteController routeController;
- private final ProcessorFactory processorFactory;
- private final InternalProcessorFactory internalProcessorFactory;
private final InflightRepository inflightRepository;
- private final PeriodTaskResolver periodTaskResolver;
- private final PeriodTaskScheduler periodTaskScheduler;
private final Injector injector;
private final ClassResolver classResolver;
private final Map<String, String> globalOptions;
private final String name;
- private final String description;
- private final boolean eventNotificationApplicable;
private final boolean useDataType;
private final boolean useBreadcrumb;
private final boolean dumpRoutes;
private final String mdcLoggingKeysPattern;
private final boolean useMDCLogging;
- private final String basePackageScan;
private final List<Route> routes;
private final boolean messageHistory;
private final boolean allowUseOriginalMessage;
private final boolean logExhaustedMessageBody;
private final String version;
+ private final LightweightCamelContextExtension lwCamelContextExtension = new LightweightCamelContextExtension(this);
private Date startDate;
private StartupSummaryLevel startupSummaryLevel;
@@ -224,53 +140,26 @@ public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCam
this.reference = reference;
registry = context.getRegistry();
typeConverter = new CoreTypeConverterRegistry(context.getTypeConverterRegistry());
- modelJAXBContextFactory = context.getCamelContextExtension().getModelJAXBContextFactory();
routes = Collections.unmodifiableList(context.getRoutes());
uuidGenerator = context.getUuidGenerator();
- componentResolver = context.getCamelContextExtension().getComponentResolver();
- componentNameResolver = context.getCamelContextExtension().getComponentNameResolver();
- languageResolver = context.getCamelContextExtension().getLanguageResolver();
- dataFormatResolver = context.getCamelContextExtension().getDataFormatResolver();
- healthCheckResolver = context.getCamelContextExtension().getHealthCheckResolver();
- devConsoleResolver = context.getCamelContextExtension().getDevConsoleResolver();
endpoints = context.getEndpointRegistry();
components = context.getComponentNames().stream().collect(Collectors.toMap(s -> s, context::hasComponent));
languages = context.getLanguageNames().stream().collect(Collectors.toMap(s -> s, context::resolveLanguage));
propertiesComponent = context.getPropertiesComponent();
- beanIntrospection = context.getCamelContextExtension().getBeanIntrospection();
- beanPostProcessor = context.getCamelContextExtension().getBeanPostProcessor();
- dependencyInjectionAnnotationFactory
- = context.getCamelContextExtension().getDependencyInjectionAnnotationFactory();
- headersMapFactory = context.getCamelContextExtension().getHeadersMapFactory();
- cliConnectorFactory = context.getCamelContextExtension().getCliConnectorFactory();
- exchangeFactory = context.getCamelContextExtension().getExchangeFactory();
- exchangeFactoryManager = context.getCamelContextExtension().getExchangeFactoryManager();
- modelineFactory = context.getCamelContextExtension().getModelineFactory();
- processorExchangeFactory = context.getCamelContextExtension().getProcessorExchangeFactory();
- reactiveExecutor = context.getCamelContextExtension().getReactiveExecutor();
- asyncProcessorAwaitManager = context.getCamelContextExtension().getAsyncProcessorAwaitManager();
executorServiceManager = context.getExecutorServiceManager();
shutdownStrategy = context.getShutdownStrategy();
applicationContextClassLoader = context.getApplicationContextClassLoader();
- unitOfWorkFactory = context.getCamelContextExtension().getUnitOfWorkFactory();
- processorFactory = context.getCamelContextExtension().getProcessorFactory();
- internalProcessorFactory = context.getCamelContextExtension().getInternalProcessorFactory();
routeController = context.getRouteController();
inflightRepository = context.getInflightRepository();
- periodTaskResolver = context.getCamelContextExtension().getPeriodTaskResolver();
- periodTaskScheduler = context.getCamelContextExtension().getPeriodTaskScheduler();
globalOptions = context.getGlobalOptions();
injector = context.getInjector();
classResolver = context.getClassResolver();
name = context.getName();
- description = context.getDescription();
- eventNotificationApplicable = context.getCamelContextExtension().isEventNotificationApplicable();
useDataType = context.isUseDataType();
useBreadcrumb = context.isUseBreadcrumb();
dumpRoutes = context.isDumpRoutes();
mdcLoggingKeysPattern = context.getMDCLoggingKeysPattern();
useMDCLogging = context.isUseMDCLogging();
- basePackageScan = context.getCamelContextExtension().getBasePackageScan();
messageHistory = context.isMessageHistory();
allowUseOriginalMessage = context.isAllowUseOriginalMessage();
logExhaustedMessageBody = context.isLogExhaustedMessageBody();
@@ -278,40 +167,9 @@ public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCam
startupSummaryLevel = context.getStartupSummaryLevel();
}
- /**
- * Normalize uri so we can do endpoint hits with minor mistakes and parameters is not in the same order.
- *
- * @param uri the uri
- * @return normalized uri
- * @throws ResolveEndpointFailedException if uri cannot be normalized
- */
- protected static String normalizeEndpointUri(String uri) {
- try {
- uri = URISupport.normalizeUri(uri);
- } catch (Exception e) {
- throw new ResolveEndpointFailedException(uri, e);
- }
- return uri;
- }
-
//
// Lifecycle
//
-
- public CamelContext getCamelContextReference() {
- return reference;
- }
-
- @Override
- public byte getStatusPhase() {
- return reference.getCamelContextExtension().getStatusPhase();
- }
-
- @Override
- public void disposeModel() {
- // noop
- }
-
@Override
public boolean isStarted() {
return false;
@@ -370,14 +228,14 @@ public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCam
@Override
public void start() {
startDate = new Date();
- LOG.info("Apache Camel {} ({}) is starting", getVersion(), getName());
+ LOG.info("Apache Camel {} ({}) is starting", getVersion(), lwCamelContextExtension.getName());
for (Route route : routes) {
route.getConsumer().start();
}
if (LOG.isInfoEnabled()) {
long l = System.currentTimeMillis() - startDate.getTime();
LOG.info("Apache Camel {} ({}) {} routes started in {}",
- getVersion(), getName(), routes.size(), TimeUtils.printDuration(l, true));
+ getVersion(), lwCamelContextExtension.getName(), routes.size(), TimeUtils.printDuration(l, true));
}
}
@@ -530,16 +388,6 @@ public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCam
throw new UnsupportedOperationException();
}
- @Override
- public Registry getRegistry() {
- return registry;
- }
-
- @Override
- public void setRegistry(Registry registry) {
- throw new UnsupportedOperationException();
- }
-
@Override
public TypeConverterRegistry getTypeConverterRegistry() {
return typeConverter;
@@ -551,73 +399,8 @@ public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCam
}
@Override
- public ModelJAXBContextFactory getModelJAXBContextFactory() {
- return modelJAXBContextFactory;
- }
-
- @Override
- public void setModelJAXBContextFactory(ModelJAXBContextFactory modelJAXBContextFactory) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ComponentResolver getComponentResolver() {
- return componentResolver;
- }
-
- @Override
- public void setComponentResolver(ComponentResolver componentResolver) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ComponentNameResolver getComponentNameResolver() {
- return componentNameResolver;
- }
-
- @Override
- public void setComponentNameResolver(ComponentNameResolver componentResolver) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public LanguageResolver getLanguageResolver() {
- return languageResolver;
- }
-
- @Override
- public void setLanguageResolver(LanguageResolver languageResolver) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public DataFormatResolver getDataFormatResolver() {
- return dataFormatResolver;
- }
-
- @Override
- public void setDataFormatResolver(DataFormatResolver dataFormatResolver) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public HealthCheckResolver getHealthCheckResolver() {
- return healthCheckResolver;
- }
-
- @Override
- public void setHealthCheckResolver(HealthCheckResolver healthCheckResolver) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public DevConsoleResolver getDevConsoleResolver() {
- return devConsoleResolver;
- }
-
- @Override
- public void setDevConsoleResolver(DevConsoleResolver devConsoleResolver) {
- throw new UnsupportedOperationException();
+ public Registry getRegistry() {
+ return null;
}
@Override
@@ -632,8 +415,7 @@ public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCam
@Override
public ExtendedCamelContext getCamelContextExtension() {
- // TODO: implement
- throw new UnsupportedOperationException();
+ return lwCamelContextExtension;
}
@Override
@@ -656,19 +438,9 @@ public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCam
return name;
}
- @Override
- public void setName(String name) {
- throw new UnsupportedOperationException();
- }
-
@Override
public String getDescription() {
- return description;
- }
-
- @Override
- public void setDescription(String description) {
- throw new UnsupportedOperationException();
+ return lwCamelContextExtension.getDescription();
}
@Override
@@ -757,15 +529,6 @@ public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCam
return false;
}
- @Override
- public void addBootstrap(BootstrapCloseable bootstrap) {
- }
-
- @Override
- public List<Service> getServices() {
- return null;
- }
-
@Override
public boolean hasService(Object object) {
return false;
@@ -826,12 +589,12 @@ public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCam
@Override
public Endpoint getEndpoint(String uri) {
- return doGetEndpoint(uri, false, false);
+ return lwCamelContextExtension.doGetEndpoint(uri, false, false);
}
@Override
public Endpoint getEndpoint(String uri, Map<String, Object> parameters) {
- return doGetEndpoint(uri, parameters, false);
+ return lwCamelContextExtension.doGetEndpoint(uri, parameters, false);
}
@Override
@@ -975,7 +738,7 @@ public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCam
}
}
// language not known or not singleton, then use resolver
- answer = getLanguageResolver().resolveLanguage(language, reference);
+ answer = lwCamelContextExtension.getLanguageResolver().resolveLanguage(language, reference);
// inject CamelContext if aware
if (answer != null) {
CamelContextAware.trySetCamelContext(answer, reference);
@@ -994,28 +757,7 @@ public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCam
@Override
public String resolvePropertyPlaceholders(String text) {
- return resolvePropertyPlaceholders(text, false);
- }
-
- @Override
- public String resolvePropertyPlaceholders(String text, boolean keepUnresolvedOptional) {
- if (text != null && text.contains(PropertiesComponent.PREFIX_TOKEN)) {
- // the parser will throw exception if property key was not found
- return getPropertiesComponent().parseUri(text, keepUnresolvedOptional);
- }
- // is the value a known field (currently we only support
- // constants from Exchange.class)
- if (text != null && text.startsWith("Exchange.")) {
- String field = StringHelper.after(text, "Exchange.");
- String constant = ExchangeConstantProvider.lookup(field);
- if (constant != null) {
- return constant;
- } else {
- throw new IllegalArgumentException("Constant field with name: " + field + " not found on Exchange.class");
- }
- }
- // return original text as is
- return text;
+ return lwCamelContextExtension.resolvePropertyPlaceholders(text, false);
}
@Override
@@ -1305,16 +1047,6 @@ public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCam
throw new UnsupportedOperationException();
}
- @Override
- public String getBasePackageScan() {
- return basePackageScan;
- }
-
- @Override
- public void setBasePackageScan(String basePackageScan) {
- throw new UnsupportedOperationException();
- }
-
@Override
public Boolean isDumpRoutes() {
return dumpRoutes;
@@ -1405,925 +1137,228 @@ public class LightweightRuntimeCamelContext implements CamelContext, ExtendedCam
return startupSummaryLevel;
}
- @Override
- public Endpoint getPrototypeEndpoint(String uri) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public Endpoint getPrototypeEndpoint(NormalizedEndpointUri uri) {
- throw new UnsupportedOperationException();
- }
- @Override
- public Endpoint hasEndpoint(NormalizedEndpointUri uri) {
- return endpoints.get(uri);
- }
- @Override
- public Endpoint getEndpoint(NormalizedEndpointUri uri) {
- return doGetEndpoint(uri.getUri(), true, false);
- }
+ //
+ // Unsupported mutable methods
+ //
@Override
- public Endpoint getEndpoint(NormalizedEndpointUri uri, Map<String, Object> parameters) {
- return doGetEndpoint(uri.getUri(), parameters, true);
- }
-
- protected Endpoint doGetEndpoint(String uri, boolean normalized, boolean prototype) {
- StringHelper.notEmpty(uri, "uri");
- // in case path has property placeholders then try to let property
- // component resolve those
- if (!normalized) {
- try {
- uri = resolvePropertyPlaceholders(uri);
- } catch (Exception e) {
- throw new ResolveEndpointFailedException(uri, e);
+ public String getComponentParameterJsonSchema(String componentName) throws IOException {
+ Class<?> clazz;
+ Object instance = lwCamelContextExtension.getRegistry().lookupByNameAndType(componentName, Component.class);
+ if (instance != null) {
+ clazz = instance.getClass();
+ } else {
+ clazz = lwCamelContextExtension.getFactoryFinder(DefaultComponentResolver.RESOURCE_PATH).findClass(componentName).orElse(null);
+ if (clazz == null) {
+ instance = hasComponent(componentName);
+ if (instance != null) {
+ clazz = instance.getClass();
+ } else {
+ return null;
+ }
}
}
- // normalize uri so we can do endpoint hits with minor mistakes and
- // parameters is not in the same order
- if (!normalized) {
- uri = normalizeEndpointUri(uri);
- }
- Endpoint answer = null;
- if (!prototype) {
- // use optimized method to get the endpoint uri
- NormalizedUri key = NormalizedUri.newNormalizedUri(uri, true);
- // only lookup and reuse existing endpoints if not prototype scoped
- answer = endpoints.get(key);
- }
- // unknown scheme
- if (answer == null) {
- throw new NoSuchEndpointException(uri);
- }
- return answer;
- }
- protected Endpoint doGetEndpoint(String uri, Map<String, Object> parameters, boolean normalized) {
- StringHelper.notEmpty(uri, "uri");
- // in case path has property placeholders then try to let property
- // component resolve those
- if (!normalized) {
- try {
- uri = resolvePropertyPlaceholders(uri);
- } catch (Exception e) {
- throw new ResolveEndpointFailedException(uri, e);
- }
- }
- // normalize uri so we can do endpoint hits with minor mistakes and
- // parameters is not in the same order
- if (!normalized) {
- uri = normalizeEndpointUri(uri);
- }
- Endpoint answer;
- String scheme = null;
- // use optimized method to get the endpoint uri
- NormalizedUri key = NormalizedUri.newNormalizedUri(uri, true);
- answer = endpoints.get(key);
- // unknown scheme
- if (answer == null) {
- throw new ResolveEndpointFailedException(uri, "No component found with scheme: " + scheme);
- }
- return answer;
+ return getJsonSchema(clazz.getPackage().getName(), componentName);
}
@Override
- public NormalizedEndpointUri normalizeUri(String uri) {
- try {
- uri = resolvePropertyPlaceholders(uri);
- return NormalizedUri.newNormalizedUri(uri, false);
- } catch (Exception e) {
- throw new ResolveEndpointFailedException(uri, e);
+ public String getDataFormatParameterJsonSchema(String dataFormatName) throws IOException {
+ Class<?> clazz;
+ Object instance = lwCamelContextExtension.getRegistry().lookupByNameAndType(dataFormatName, DataFormat.class);
+ if (instance != null) {
+ clazz = instance.getClass();
+ } else {
+ clazz = lwCamelContextExtension.getFactoryFinder(DefaultDataFormatResolver.DATAFORMAT_RESOURCE_PATH).findClass(dataFormatName).orElse(null);
+ if (clazz == null) {
+ return null;
+ }
}
+ return getJsonSchema(clazz.getPackage().getName(), dataFormatName);
}
@Override
- public List<RouteStartupOrder> getRouteStartupOrder() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public CamelBeanPostProcessor getBeanPostProcessor() {
- return beanPostProcessor;
- }
-
- @Override
- public void setBeanPostProcessor(CamelBeanPostProcessor beanPostProcessor) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public CamelDependencyInjectionAnnotationFactory getDependencyInjectionAnnotationFactory() {
- return dependencyInjectionAnnotationFactory;
- }
-
- @Override
- public void setDependencyInjectionAnnotationFactory(CamelDependencyInjectionAnnotationFactory factory) {
- throw new UnsupportedOperationException();
+ public String getLanguageParameterJsonSchema(String languageName) throws IOException {
+ Class<?> clazz;
+ Object instance = lwCamelContextExtension.getRegistry().lookupByNameAndType(languageName, Language.class);
+ if (instance != null) {
+ clazz = instance.getClass();
+ } else {
+ clazz = lwCamelContextExtension.getFactoryFinder(DefaultLanguageResolver.LANGUAGE_RESOURCE_PATH).findClass(languageName).orElse(null);
+ if (clazz == null) {
+ return null;
+ }
+ }
+ return getJsonSchema(clazz.getPackage().getName(), languageName);
}
@Override
- public ManagementMBeanAssembler getManagementMBeanAssembler() {
- throw new UnsupportedOperationException();
+ public String getEipParameterJsonSchema(String eipName) throws IOException {
+ // the eip json schema may be in some of the sub-packages so look until
+ // we find it
+ String[] subPackages = new String[] { "", "/config", "/dataformat", "/language", "/loadbalancer", "/rest" };
+ for (String sub : subPackages) {
+ String path = CamelContextHelper.MODEL_DOCUMENTATION_PREFIX + sub + "/" + eipName + ".json";
+ InputStream inputStream = getClassResolver().loadResourceAsStream(path);
+ if (inputStream != null) {
+ try {
+ return IOHelper.loadText(inputStream);
+ } finally {
+ IOHelper.close(inputStream);
+ }
+ }
+ }
+ return null;
}
- @Override
- public ErrorHandlerFactory getErrorHandlerFactory() {
- throw new UnsupportedOperationException();
+ private String getJsonSchema(String packageName, String name) throws IOException {
+ String path = packageName.replace('.', '/') + "/" + name + ".json";
+ InputStream inputStream = getClassResolver().loadResourceAsStream(path);
+ if (inputStream != null) {
+ try {
+ return IOHelper.loadText(inputStream);
+ } finally {
+ IOHelper.close(inputStream);
+ }
+ }
+ return null;
}
- //
- // Unsupported mutable methods
- //
-
@Override
- public void setErrorHandlerFactory(ErrorHandlerFactory errorHandlerFactory) {
+ public Endpoint addEndpoint(String uri, Endpoint endpoint) throws Exception {
throw new UnsupportedOperationException();
}
@Override
- public PackageScanClassResolver getPackageScanClassResolver() {
+ public void removeEndpoint(Endpoint endpoint) throws Exception {
throw new UnsupportedOperationException();
}
@Override
- public void setPackageScanClassResolver(PackageScanClassResolver resolver) {
+ public Collection<Endpoint> removeEndpoints(String pattern) throws Exception {
throw new UnsupportedOperationException();
}
@Override
- public PackageScanResourceResolver getPackageScanResourceResolver() {
+ public void addComponent(String componentName, Component component) {
throw new UnsupportedOperationException();
}
@Override
- public void setPackageScanResourceResolver(PackageScanResourceResolver resolver) {
+ public Component removeComponent(String componentName) {
throw new UnsupportedOperationException();
}
@Override
- public FactoryFinder getDefaultFactoryFinder() {
+ public void addRoutes(RoutesBuilder builder) throws Exception {
throw new UnsupportedOperationException();
}
@Override
- public ConfigurerResolver getBootstrapConfigurerResolver() {
+ public void addTemplatedRoutes(RoutesBuilder builder) throws Exception {
throw new UnsupportedOperationException();
}
@Override
- public void setBootstrapConfigurerResolver(ConfigurerResolver configurerResolver) {
+ public void addRoutesConfigurations(RouteConfigurationsBuilder builder) throws Exception {
throw new UnsupportedOperationException();
}
@Override
- public FactoryFinder getBootstrapFactoryFinder() {
+ public boolean removeRoute(String routeId) throws Exception {
throw new UnsupportedOperationException();
}
@Override
- public void setBootstrapFactoryFinder(FactoryFinder factoryFinder) {
+ public void addRoutePolicyFactory(RoutePolicyFactory routePolicyFactory) {
throw new UnsupportedOperationException();
}
@Override
- public FactoryFinder getBootstrapFactoryFinder(String path) {
+ public void setTracing(Boolean tracing) {
throw new UnsupportedOperationException();
}
@Override
- public FactoryFinder getFactoryFinder(String path) {
+ public void setBacklogTracing(Boolean backlogTrace) {
throw new UnsupportedOperationException();
}
@Override
- public FactoryFinderResolver getFactoryFinderResolver() {
+ public void setDebugging(Boolean debugging) {
throw new UnsupportedOperationException();
}
@Override
- public void setFactoryFinderResolver(FactoryFinderResolver resolver) {
+ public void setMessageHistory(Boolean messageHistory) {
throw new UnsupportedOperationException();
}
@Override
- public ProcessorFactory getProcessorFactory() {
- return processorFactory;
- }
-
- @Override
- public void setProcessorFactory(ProcessorFactory processorFactory) {
+ public void setLogMask(Boolean logMask) {
throw new UnsupportedOperationException();
}
@Override
- public ModelineFactory getModelineFactory() {
- return modelineFactory;
- }
-
- @Override
- public void setModelineFactory(ModelineFactory modelineFactory) {
+ public void setLogExhaustedMessageBody(Boolean logExhaustedMessageBody) {
throw new UnsupportedOperationException();
}
@Override
- public InternalProcessorFactory getInternalProcessorFactory() {
- return internalProcessorFactory;
- }
-
- @Override
- public void setInternalProcessorFactory(InternalProcessorFactory internalProcessorFactory) {
+ public void setAutoStartup(Boolean autoStartup) {
throw new UnsupportedOperationException();
}
@Override
- public InterceptEndpointFactory getInterceptEndpointFactory() {
+ public void addLifecycleStrategy(LifecycleStrategy lifecycleStrategy) {
throw new UnsupportedOperationException();
}
@Override
- public void setInterceptEndpointFactory(InterceptEndpointFactory interceptEndpointFactory) {
+ public String addRouteFromTemplate(String routeId, String routeTemplateId, Map<String, Object> parameters)
+ throws Exception {
throw new UnsupportedOperationException();
}
@Override
- public RouteFactory getRouteFactory() {
+ public String addRouteFromTemplate(String routeId, String routeTemplateId, String prefixId, Map<String, Object> parameters)
+ throws Exception {
throw new UnsupportedOperationException();
}
@Override
- public void setRouteFactory(RouteFactory routeFactory) {
+ public String addRouteFromTemplate(String routeId, String routeTemplateId, RouteTemplateContext routeTemplateContext)
+ throws Exception {
throw new UnsupportedOperationException();
}
@Override
- public DeferServiceFactory getDeferServiceFactory() {
+ public String addRouteFromTemplate(
+ String routeId, String routeTemplateId, String prefixId, RouteTemplateContext routeTemplateContext)
+ throws Exception {
throw new UnsupportedOperationException();
}
@Override
- public void setDeferServiceFactory(DeferServiceFactory deferServiceFactory) {
+ public void removeRouteTemplates(String pattern) throws Exception {
throw new UnsupportedOperationException();
}
- @Override
- public UnitOfWorkFactory getUnitOfWorkFactory() {
- return unitOfWorkFactory;
+ private void startService(Service service) throws Exception {
+ // and register startup aware so they can be notified when
+ // camel context has been started
+ if (service instanceof StartupListener) {
+ StartupListener listener = (StartupListener) service;
+ addStartupListener(listener);
+ }
+ CamelContextAware.trySetCamelContext(service, reference);
+ service.start();
}
- @Override
- public void setUnitOfWorkFactory(UnitOfWorkFactory unitOfWorkFactory) {
- throw new UnsupportedOperationException();
+ public ExtendedCamelContext getLwCamelContextExtension() {
+ return lwCamelContextExtension;
}
- @Override
- public AnnotationBasedProcessorFactory getAnnotationBasedProcessorFactory() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setAnnotationBasedProcessorFactory(AnnotationBasedProcessorFactory annotationBasedProcessorFactory) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public BeanProxyFactory getBeanProxyFactory() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public BeanProcessorFactory getBeanProcessorFactory() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ScheduledExecutorService getErrorHandlerExecutorService() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public List<InterceptStrategy> getInterceptStrategies() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public Set<LogListener> getLogListeners() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public AsyncProcessorAwaitManager getAsyncProcessorAwaitManager() {
- return asyncProcessorAwaitManager;
- }
-
- @Override
- public void setAsyncProcessorAwaitManager(AsyncProcessorAwaitManager manager) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public BeanIntrospection getBeanIntrospection() {
- return beanIntrospection;
- }
-
- @Override
- public void setBeanIntrospection(BeanIntrospection beanIntrospection) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public HeadersMapFactory getHeadersMapFactory() {
- return headersMapFactory;
- }
-
- @Override
- public void setHeadersMapFactory(HeadersMapFactory factory) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public CliConnectorFactory getCliConnectorFactory() {
- return cliConnectorFactory;
- }
-
- @Override
- public void setCliConnectorFactory(CliConnectorFactory cliConnectorFactory) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ExchangeFactory getExchangeFactory() {
- return exchangeFactory;
- }
-
- @Override
- public ExchangeFactoryManager getExchangeFactoryManager() {
- return exchangeFactoryManager;
- }
-
- @Override
- public void setExchangeFactoryManager(ExchangeFactoryManager exchangeFactoryManager) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setExchangeFactory(ExchangeFactory exchangeFactory) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ProcessorExchangeFactory getProcessorExchangeFactory() {
- return processorExchangeFactory;
- }
-
- @Override
- public void setProcessorExchangeFactory(ProcessorExchangeFactory processorExchangeFactory) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ReactiveExecutor getReactiveExecutor() {
- return reactiveExecutor;
- }
-
- @Override
- public void setReactiveExecutor(ReactiveExecutor reactiveExecutor) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public boolean isEventNotificationApplicable() {
- return eventNotificationApplicable;
- }
-
- @Override
- public void setEventNotificationApplicable(boolean eventNotificationApplicable) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ModelToXMLDumper getModelToXMLDumper() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setModelToXMLDumper(ModelToXMLDumper modelToXMLDumper) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public RuntimeCamelCatalog getRuntimeCamelCatalog() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setRuntimeCamelCatalog(RuntimeCamelCatalog runtimeCamelCatalog) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ConfigurerResolver getConfigurerResolver() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setConfigurerResolver(ConfigurerResolver configurerResolver) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void addRoute(Route route) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void removeRoute(Route route) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public Processor createErrorHandler(Route route, Processor processor) throws Exception {
- // TODO: need to revisit this in order to support dynamic endpoints uri
- throw new UnsupportedOperationException();
- }
-
- @Override
- public String getComponentParameterJsonSchema(String componentName) throws IOException {
- Class<?> clazz;
- Object instance = getRegistry().lookupByNameAndType(componentName, Component.class);
- if (instance != null) {
- clazz = instance.getClass();
- } else {
- clazz = getFactoryFinder(DefaultComponentResolver.RESOURCE_PATH).findClass(componentName).orElse(null);
- if (clazz == null) {
- instance = hasComponent(componentName);
- if (instance != null) {
- clazz = instance.getClass();
- } else {
- return null;
- }
- }
- }
- // special for ActiveMQ as it is really just JMS
- if ("ActiveMQComponent".equals(clazz.getSimpleName())) {
- return getComponentParameterJsonSchema("jms");
- } else {
- return getJsonSchema(clazz.getPackage().getName(), componentName);
- }
- }
-
- @Override
- public String getDataFormatParameterJsonSchema(String dataFormatName) throws IOException {
- Class<?> clazz;
- Object instance = getRegistry().lookupByNameAndType(dataFormatName, DataFormat.class);
- if (instance != null) {
- clazz = instance.getClass();
- } else {
- clazz = getFactoryFinder(DefaultDataFormatResolver.DATAFORMAT_RESOURCE_PATH).findClass(dataFormatName).orElse(null);
- if (clazz == null) {
- return null;
- }
- }
- return getJsonSchema(clazz.getPackage().getName(), dataFormatName);
- }
-
- @Override
- public String getLanguageParameterJsonSchema(String languageName) throws IOException {
- Class<?> clazz;
- Object instance = getRegistry().lookupByNameAndType(languageName, Language.class);
- if (instance != null) {
- clazz = instance.getClass();
- } else {
- clazz = getFactoryFinder(DefaultLanguageResolver.LANGUAGE_RESOURCE_PATH).findClass(languageName).orElse(null);
- if (clazz == null) {
- return null;
- }
- }
- return getJsonSchema(clazz.getPackage().getName(), languageName);
- }
-
- @Override
- public String getEipParameterJsonSchema(String eipName) throws IOException {
- // the eip json schema may be in some of the sub-packages so look until
- // we find it
- String[] subPackages = new String[] { "", "/config", "/dataformat", "/language", "/loadbalancer", "/rest" };
- for (String sub : subPackages) {
- String path = CamelContextHelper.MODEL_DOCUMENTATION_PREFIX + sub + "/" + eipName + ".json";
- InputStream inputStream = getClassResolver().loadResourceAsStream(path);
- if (inputStream != null) {
- try {
- return IOHelper.loadText(inputStream);
- } finally {
- IOHelper.close(inputStream);
- }
- }
- }
- return null;
- }
-
- private String getJsonSchema(String packageName, String name) throws IOException {
- String path = packageName.replace('.', '/') + "/" + name + ".json";
- InputStream inputStream = getClassResolver().loadResourceAsStream(path);
- if (inputStream != null) {
- try {
- return IOHelper.loadText(inputStream);
- } finally {
- IOHelper.close(inputStream);
- }
- }
- return null;
- }
-
- @Override
- public void setupRoutes(boolean done) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public boolean isSetupRoutes() {
- return false;
- }
-
- @Override
- public void addInterceptStrategy(InterceptStrategy interceptStrategy) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setupManagement(Map<String, Object> options) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void addLogListener(LogListener listener) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public RestBindingJaxbDataFormatFactory getRestBindingJaxbDataFormatFactory() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setRestBindingJaxbDataFormatFactory(RestBindingJaxbDataFormatFactory restBindingJaxbDataFormatFactory) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setRoutesLoader(RoutesLoader routesLoader) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public RoutesLoader getRoutesLoader() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public ResourceLoader getResourceLoader() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setResourceLoader(ResourceLoader resourceLoader) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void registerEndpointCallback(EndpointStrategy strategy) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public Endpoint addEndpoint(String uri, Endpoint endpoint) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void removeEndpoint(Endpoint endpoint) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public Collection<Endpoint> removeEndpoints(String pattern) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public NodeIdFactory getNodeIdFactory() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setNodeIdFactory(NodeIdFactory factory) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void addComponent(String componentName, Component component) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public Component removeComponent(String componentName) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void addRoutes(RoutesBuilder builder) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void addTemplatedRoutes(RoutesBuilder builder) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void addRoutesConfigurations(RouteConfigurationsBuilder builder) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public boolean removeRoute(String routeId) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void addRoutePolicyFactory(RoutePolicyFactory routePolicyFactory) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setTracing(Boolean tracing) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setBacklogTracing(Boolean backlogTrace) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setDebugging(Boolean debugging) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setMessageHistory(Boolean messageHistory) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setLogMask(Boolean logMask) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setLogExhaustedMessageBody(Boolean logExhaustedMessageBody) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setAutoStartup(Boolean autoStartup) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void addLifecycleStrategy(LifecycleStrategy lifecycleStrategy) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public String addRouteFromTemplate(String routeId, String routeTemplateId, Map<String, Object> parameters)
- throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public String addRouteFromTemplate(String routeId, String routeTemplateId, String prefixId, Map<String, Object> parameters)
- throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public String addRouteFromTemplate(String routeId, String routeTemplateId, RouteTemplateContext routeTemplateContext)
- throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public String addRouteFromTemplate(
- String routeId, String routeTemplateId, String prefixId, RouteTemplateContext routeTemplateContext)
- throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void removeRouteTemplates(String pattern) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setLightweight(boolean lightweight) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public boolean isLightweight() {
- return true;
- }
-
- @Override
- public String getTestExcludeRoutes() {
- return null;
- }
-
- @Override
- public RouteController getInternalRouteController() {
- return new RouteController() {
- @Override
- public LoggingLevel getLoggingLevel() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setLoggingLevel(LoggingLevel loggingLevel) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public boolean isSupervising() {
- return false;
- }
-
- @Override
- public SupervisingRouteController supervising() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public <T extends RouteController> T adapt(Class<T> type) {
- return type.cast(this);
- }
-
- @Override
- public Collection<Route> getControlledRoutes() {
- return routes;
- }
-
- @Override
- public void startAllRoutes() throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void stopAllRoutes() throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void removeAllRoutes() throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public boolean isStartingRoutes() {
- return false;
- }
-
- @Override
- public void reloadAllRoutes() throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public boolean isReloadingRoutes() {
- return false;
- }
-
- @Override
- public ServiceStatus getRouteStatus(String routeId) {
- return ServiceStatus.Started;
- }
-
- @Override
- public void startRoute(String routeId) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void stopRoute(String routeId) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void stopRoute(String routeId, Throwable cause) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void stopRoute(String routeId, long timeout, TimeUnit timeUnit) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public boolean stopRoute(String routeId, long timeout, TimeUnit timeUnit, boolean abortAfterTimeout)
- throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void suspendRoute(String routeId) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void suspendRoute(String routeId, long timeout, TimeUnit timeUnit) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void resumeRoute(String routeId) throws Exception {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public CamelContext getCamelContext() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setCamelContext(CamelContext camelContext) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void start() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void stop() {
- throw new UnsupportedOperationException();
- }
- };
- }
-
- @Override
- public UriFactoryResolver getUriFactoryResolver() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setUriFactoryResolver(UriFactoryResolver uriFactoryResolver) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public EndpointUriFactory getEndpointUriFactory(String scheme) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public StartupStepRecorder getStartupStepRecorder() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void setStartupStepRecorder(StartupStepRecorder startupStepRecorder) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public PeriodTaskResolver getPeriodTaskResolver() {
- return periodTaskResolver;
- }
-
- @Override
- public void setPeriodTaskScheduler(PeriodTaskScheduler periodTaskScheduler) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public PeriodTaskScheduler getPeriodTaskScheduler() {
- return periodTaskScheduler;
- }
-
- @Override
- public void setPeriodTaskResolver(PeriodTaskResolver periodTaskResolver) {
- throw new UnsupportedOperationException();
- }
-
- private void startService(Service service) throws Exception {
- // and register startup aware so they can be notified when
- // camel context has been started
- if (service instanceof StartupListener) {
- StartupListener listener = (StartupListener) service;
- addStartupListener(listener);
- }
- CamelContextAware.trySetCamelContext(service, reference);
- service.start();
- }
}
[camel] 01/02: CAMEL-19086: split the ExtendedCamelContext from the Context for the LightweightCamelContext
Posted by or...@apache.org.
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 fe2ee35a4b19162fe9c604d2412a93ad39052a96
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu Feb 23 13:14:19 2023 +0100
CAMEL-19086: split the ExtendedCamelContext from the Context for the LightweightCamelContext
---
.../camel/impl/lw/LightweightCamelContext.java | 699 +--------------------
.../java/org/apache/camel/ContextTestSupport.java | 3 +-
2 files changed, 3 insertions(+), 699 deletions(-)
diff --git a/core/camel-core-engine/src/main/java/org/apache/camel/impl/lw/LightweightCamelContext.java b/core/camel-core-engine/src/main/java/org/apache/camel/impl/lw/LightweightCamelContext.java
index 77a24453813..a035754b143 100644
--- a/core/camel-core-engine/src/main/java/org/apache/camel/impl/lw/LightweightCamelContext.java
+++ b/core/camel-core-engine/src/main/java/org/apache/camel/impl/lw/LightweightCamelContext.java
@@ -22,7 +22,6 @@ import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.Set;
-import java.util.concurrent.ScheduledExecutorService;
import java.util.function.Function;
import org.apache.camel.CamelContext;
@@ -30,7 +29,6 @@ import org.apache.camel.CatalogCamelContext;
import org.apache.camel.Component;
import org.apache.camel.ConsumerTemplate;
import org.apache.camel.Endpoint;
-import org.apache.camel.ErrorHandlerFactory;
import org.apache.camel.Experimental;
import org.apache.camel.Expression;
import org.apache.camel.ExtendedCamelContext;
@@ -44,7 +42,6 @@ import org.apache.camel.Route;
import org.apache.camel.RouteConfigurationsBuilder;
import org.apache.camel.RouteTemplateContext;
import org.apache.camel.RoutesBuilder;
-import org.apache.camel.Service;
import org.apache.camel.ServiceStatus;
import org.apache.camel.ShutdownRoute;
import org.apache.camel.ShutdownRunningTask;
@@ -53,9 +50,6 @@ import org.apache.camel.StartupSummaryLevel;
import org.apache.camel.TypeConverter;
import org.apache.camel.ValueHolder;
import org.apache.camel.builder.AdviceWithRouteBuilder;
-import org.apache.camel.catalog.RuntimeCamelCatalog;
-import org.apache.camel.console.DevConsoleResolver;
-import org.apache.camel.health.HealthCheckResolver;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.camel.model.DataFormatDefinition;
import org.apache.camel.model.FaultToleranceConfigurationDefinition;
@@ -72,82 +66,35 @@ import org.apache.camel.model.language.ExpressionDefinition;
import org.apache.camel.model.rest.RestDefinition;
import org.apache.camel.model.transformer.TransformerDefinition;
import org.apache.camel.model.validator.ValidatorDefinition;
-import org.apache.camel.spi.AnnotationBasedProcessorFactory;
-import org.apache.camel.spi.AsyncProcessorAwaitManager;
-import org.apache.camel.spi.BeanIntrospection;
-import org.apache.camel.spi.BeanProcessorFactory;
-import org.apache.camel.spi.BeanProxyFactory;
import org.apache.camel.spi.BeanRepository;
-import org.apache.camel.spi.BootstrapCloseable;
-import org.apache.camel.spi.CamelBeanPostProcessor;
import org.apache.camel.spi.CamelContextNameStrategy;
-import org.apache.camel.spi.CamelDependencyInjectionAnnotationFactory;
import org.apache.camel.spi.ClassResolver;
-import org.apache.camel.spi.CliConnectorFactory;
-import org.apache.camel.spi.ComponentNameResolver;
-import org.apache.camel.spi.ComponentResolver;
-import org.apache.camel.spi.ConfigurerResolver;
import org.apache.camel.spi.DataFormat;
-import org.apache.camel.spi.DataFormatResolver;
import org.apache.camel.spi.DataType;
import org.apache.camel.spi.Debugger;
-import org.apache.camel.spi.DeferServiceFactory;
import org.apache.camel.spi.EndpointRegistry;
-import org.apache.camel.spi.EndpointStrategy;
-import org.apache.camel.spi.EndpointUriFactory;
-import org.apache.camel.spi.ExchangeFactory;
-import org.apache.camel.spi.ExchangeFactoryManager;
import org.apache.camel.spi.ExecutorServiceManager;
-import org.apache.camel.spi.FactoryFinder;
-import org.apache.camel.spi.FactoryFinderResolver;
-import org.apache.camel.spi.HeadersMapFactory;
import org.apache.camel.spi.InflightRepository;
import org.apache.camel.spi.Injector;
-import org.apache.camel.spi.InterceptEndpointFactory;
-import org.apache.camel.spi.InterceptStrategy;
-import org.apache.camel.spi.InternalProcessorFactory;
import org.apache.camel.spi.Language;
-import org.apache.camel.spi.LanguageResolver;
import org.apache.camel.spi.LifecycleStrategy;
-import org.apache.camel.spi.LogListener;
-import org.apache.camel.spi.ManagementMBeanAssembler;
import org.apache.camel.spi.ManagementNameStrategy;
import org.apache.camel.spi.ManagementStrategy;
import org.apache.camel.spi.MessageHistoryFactory;
-import org.apache.camel.spi.ModelJAXBContextFactory;
import org.apache.camel.spi.ModelReifierFactory;
-import org.apache.camel.spi.ModelToXMLDumper;
-import org.apache.camel.spi.ModelineFactory;
-import org.apache.camel.spi.NodeIdFactory;
-import org.apache.camel.spi.NormalizedEndpointUri;
-import org.apache.camel.spi.PackageScanClassResolver;
-import org.apache.camel.spi.PackageScanResourceResolver;
-import org.apache.camel.spi.PeriodTaskResolver;
-import org.apache.camel.spi.PeriodTaskScheduler;
-import org.apache.camel.spi.ProcessorExchangeFactory;
-import org.apache.camel.spi.ProcessorFactory;
import org.apache.camel.spi.PropertiesComponent;
-import org.apache.camel.spi.ReactiveExecutor;
import org.apache.camel.spi.Registry;
-import org.apache.camel.spi.ResourceLoader;
-import org.apache.camel.spi.RestBindingJaxbDataFormatFactory;
import org.apache.camel.spi.RestConfiguration;
import org.apache.camel.spi.RestRegistry;
import org.apache.camel.spi.RouteController;
-import org.apache.camel.spi.RouteFactory;
import org.apache.camel.spi.RoutePolicyFactory;
-import org.apache.camel.spi.RouteStartupOrder;
-import org.apache.camel.spi.RoutesLoader;
import org.apache.camel.spi.RuntimeEndpointRegistry;
import org.apache.camel.spi.ShutdownStrategy;
-import org.apache.camel.spi.StartupStepRecorder;
import org.apache.camel.spi.StreamCachingStrategy;
import org.apache.camel.spi.Tracer;
import org.apache.camel.spi.Transformer;
import org.apache.camel.spi.TransformerRegistry;
import org.apache.camel.spi.TypeConverterRegistry;
-import org.apache.camel.spi.UnitOfWorkFactory;
-import org.apache.camel.spi.UriFactoryResolver;
import org.apache.camel.spi.UuidGenerator;
import org.apache.camel.spi.Validator;
import org.apache.camel.spi.ValidatorRegistry;
@@ -156,7 +103,7 @@ import org.apache.camel.support.jsse.SSLContextParameters;
import org.apache.camel.vault.VaultConfiguration;
@Experimental
-public class LightweightCamelContext implements CamelContext, ExtendedCamelContext, CatalogCamelContext, ModelCamelContext {
+public class LightweightCamelContext implements CamelContext, CatalogCamelContext, ModelCamelContext {
protected volatile CamelContext delegate;
@@ -197,21 +144,8 @@ public class LightweightCamelContext implements CamelContext, ExtendedCamelConte
*/
public LightweightCamelContext(Registry registry) {
this();
- setRegistry(registry);
- }
-
- public CamelContext getCamelContextReference() {
- return this;
- }
- @Override
- public byte getStatusPhase() {
- return delegate.getCamelContextExtension().getStatusPhase();
- }
-
- @Override
- public void disposeModel() {
- delegate.getCamelContextExtension().disposeModel();
+ getCamelContextExtension().setRegistry(registry);
}
@Override
@@ -319,11 +253,6 @@ public class LightweightCamelContext implements CamelContext, ExtendedCamelConte
return delegate.getDescription();
}
- @Override
- public void setDescription(String description) {
- delegate.getCamelContextExtension().setDescription(description);
- }
-
@Override
public ManagementNameStrategy getManagementNameStrategy() {
return delegate.getManagementNameStrategy();
@@ -369,11 +298,6 @@ public class LightweightCamelContext implements CamelContext, ExtendedCamelConte
return delegate.getStartDate();
}
- @Override
- public void addBootstrap(BootstrapCloseable bootstrap) {
- getExtendedCamelContext().addBootstrap(bootstrap);
- }
-
@Override
public void addService(Object object) throws Exception {
delegate.addService(object);
@@ -399,11 +323,6 @@ public class LightweightCamelContext implements CamelContext, ExtendedCamelConte
return delegate.removeService(object);
}
- @Override
- public List<Service> getServices() {
- return getExtendedCamelContext().getServices();
- }
-
@Override
public boolean hasService(Object object) {
return delegate.hasService(object);
@@ -669,11 +588,6 @@ public class LightweightCamelContext implements CamelContext, ExtendedCamelConte
return delegate.resolvePropertyPlaceholders(text);
}
- @Override
- public String resolvePropertyPlaceholders(String text, boolean keepUnresolvedOptional) {
- return getExtendedCamelContext().resolvePropertyPlaceholders(text, keepUnresolvedOptional);
- }
-
@Override
public PropertiesComponent getPropertiesComponent() {
return delegate.getPropertiesComponent();
@@ -969,16 +883,6 @@ public class LightweightCamelContext implements CamelContext, ExtendedCamelConte
delegate.setDumpRoutes(dumpRoutes);
}
- @Override
- public String getBasePackageScan() {
- return getExtendedCamelContext().getBasePackageScan();
- }
-
- @Override
- public void setBasePackageScan(String basePackageScan) {
- getExtendedCamelContext().setBasePackageScan(basePackageScan);
- }
-
@Override
public Boolean isUseMDCLogging() {
return delegate.isUseMDCLogging();
@@ -1224,589 +1128,11 @@ public class LightweightCamelContext implements CamelContext, ExtendedCamelConte
delegate.removeRouteTemplates(pattern);
}
- //
- // ExtendedCamelContext
- //
-
- protected ExtendedCamelContext getExtendedCamelContext() {
- return delegate.getCamelContextExtension();
- }
-
@Override
public ExtendedCamelContext getCamelContextExtension() {
return delegate.getCamelContextExtension();
}
- @Override
- public void setName(String name) {
- getExtendedCamelContext().setName(name);
- }
-
- @Override
- public void setRegistry(Registry registry) {
- getExtendedCamelContext().setRegistry(registry);
- }
-
- @Override
- public void setupRoutes(boolean done) {
- getExtendedCamelContext().setupRoutes(done);
- }
-
- @Override
- public boolean isSetupRoutes() {
- return getExtendedCamelContext().isSetupRoutes();
- }
-
- @Override
- public void registerEndpointCallback(EndpointStrategy strategy) {
- getExtendedCamelContext().registerEndpointCallback(strategy);
- }
-
- @Override
- public Endpoint getPrototypeEndpoint(String uri) {
- return getExtendedCamelContext().getPrototypeEndpoint(uri);
- }
-
- @Override
- public Endpoint getPrototypeEndpoint(NormalizedEndpointUri uri) {
- return getExtendedCamelContext().getPrototypeEndpoint(uri);
- }
-
- @Override
- public Endpoint hasEndpoint(NormalizedEndpointUri uri) {
- return getExtendedCamelContext().hasEndpoint(uri);
- }
-
- @Override
- public Endpoint getEndpoint(NormalizedEndpointUri uri) {
- return getExtendedCamelContext().getEndpoint(uri);
- }
-
- @Override
- public Endpoint getEndpoint(NormalizedEndpointUri uri, Map<String, Object> parameters) {
- return getExtendedCamelContext().getEndpoint(uri, parameters);
- }
-
- @Override
- public NormalizedEndpointUri normalizeUri(String uri) {
- return getExtendedCamelContext().normalizeUri(uri);
- }
-
- @Override
- public List<RouteStartupOrder> getRouteStartupOrder() {
- return getExtendedCamelContext().getRouteStartupOrder();
- }
-
- @Override
- public CamelBeanPostProcessor getBeanPostProcessor() {
- return getExtendedCamelContext().getBeanPostProcessor();
- }
-
- @Override
- public void setBeanPostProcessor(CamelBeanPostProcessor beanPostProcessor) {
- getExtendedCamelContext().setBeanPostProcessor(beanPostProcessor);
- }
-
- @Override
- public CamelDependencyInjectionAnnotationFactory getDependencyInjectionAnnotationFactory() {
- return getExtendedCamelContext().getDependencyInjectionAnnotationFactory();
- }
-
- @Override
- public void setDependencyInjectionAnnotationFactory(CamelDependencyInjectionAnnotationFactory factory) {
- getExtendedCamelContext().setDependencyInjectionAnnotationFactory(factory);
- }
-
- @Override
- public ManagementMBeanAssembler getManagementMBeanAssembler() {
- return getExtendedCamelContext().getManagementMBeanAssembler();
- }
-
- @Override
- public ErrorHandlerFactory getErrorHandlerFactory() {
- return getExtendedCamelContext().getErrorHandlerFactory();
- }
-
- @Override
- public void setErrorHandlerFactory(ErrorHandlerFactory errorHandlerFactory) {
- getExtendedCamelContext().setErrorHandlerFactory(errorHandlerFactory);
- }
-
- @Override
- public void setNodeIdFactory(NodeIdFactory factory) {
- getExtendedCamelContext().setNodeIdFactory(factory);
- }
-
- @Override
- public NodeIdFactory getNodeIdFactory() {
- return getExtendedCamelContext().getNodeIdFactory();
- }
-
- @Override
- public ComponentResolver getComponentResolver() {
- return getExtendedCamelContext().getComponentResolver();
- }
-
- @Override
- public void setComponentResolver(ComponentResolver componentResolver) {
- getExtendedCamelContext().setComponentResolver(componentResolver);
- }
-
- @Override
- public ComponentNameResolver getComponentNameResolver() {
- return getExtendedCamelContext().getComponentNameResolver();
- }
-
- @Override
- public void setComponentNameResolver(ComponentNameResolver componentNameResolver) {
- getExtendedCamelContext().setComponentNameResolver(componentNameResolver);
- }
-
- @Override
- public LanguageResolver getLanguageResolver() {
- return getExtendedCamelContext().getLanguageResolver();
- }
-
- @Override
- public void setLanguageResolver(LanguageResolver languageResolver) {
- getExtendedCamelContext().setLanguageResolver(languageResolver);
- }
-
- @Override
- public DataFormatResolver getDataFormatResolver() {
- return getExtendedCamelContext().getDataFormatResolver();
- }
-
- @Override
- public void setDataFormatResolver(DataFormatResolver dataFormatResolver) {
- getExtendedCamelContext().setDataFormatResolver(dataFormatResolver);
- }
-
- @Override
- public HealthCheckResolver getHealthCheckResolver() {
- return getExtendedCamelContext().getHealthCheckResolver();
- }
-
- @Override
- public void setHealthCheckResolver(HealthCheckResolver healthCheckResolver) {
- getExtendedCamelContext().setHealthCheckResolver(healthCheckResolver);
- }
-
- @Override
- public DevConsoleResolver getDevConsoleResolver() {
- return getExtendedCamelContext().getDevConsoleResolver();
- }
-
- @Override
- public void setDevConsoleResolver(DevConsoleResolver devConsoleResolver) {
- getExtendedCamelContext().setDevConsoleResolver(devConsoleResolver);
- }
-
- @Override
- public PackageScanClassResolver getPackageScanClassResolver() {
- return getExtendedCamelContext().getPackageScanClassResolver();
- }
-
- @Override
- public void setPackageScanClassResolver(PackageScanClassResolver resolver) {
- getExtendedCamelContext().setPackageScanClassResolver(resolver);
- }
-
- @Override
- public PackageScanResourceResolver getPackageScanResourceResolver() {
- return getExtendedCamelContext().getPackageScanResourceResolver();
- }
-
- @Override
- public void setPackageScanResourceResolver(PackageScanResourceResolver resolver) {
- getExtendedCamelContext().setPackageScanResourceResolver(resolver);
- }
-
- @Override
- public FactoryFinder getDefaultFactoryFinder() {
- return getExtendedCamelContext().getDefaultFactoryFinder();
- }
-
- @Override
- public ConfigurerResolver getBootstrapConfigurerResolver() {
- return getExtendedCamelContext().getBootstrapConfigurerResolver();
- }
-
- @Override
- public void setBootstrapConfigurerResolver(ConfigurerResolver configurerResolver) {
- getExtendedCamelContext().setBootstrapConfigurerResolver(configurerResolver);
- }
-
- @Override
- public FactoryFinder getBootstrapFactoryFinder() {
- return getExtendedCamelContext().getBootstrapFactoryFinder();
- }
-
- @Override
- public void setBootstrapFactoryFinder(FactoryFinder factoryFinder) {
- getExtendedCamelContext().setBootstrapFactoryFinder(factoryFinder);
- }
-
- @Override
- public FactoryFinder getBootstrapFactoryFinder(String path) {
- return getExtendedCamelContext().getBootstrapFactoryFinder(path);
- }
-
- @Override
- public FactoryFinder getFactoryFinder(String path) {
- return getExtendedCamelContext().getFactoryFinder(path);
- }
-
- @Override
- public void setFactoryFinderResolver(FactoryFinderResolver resolver) {
- getExtendedCamelContext().setFactoryFinderResolver(resolver);
- }
-
- @Override
- public FactoryFinderResolver getFactoryFinderResolver() {
- return getExtendedCamelContext().getFactoryFinderResolver();
- }
-
- @Override
- public ProcessorFactory getProcessorFactory() {
- return getExtendedCamelContext().getProcessorFactory();
- }
-
- @Override
- public void setProcessorFactory(ProcessorFactory processorFactory) {
- getExtendedCamelContext().setProcessorFactory(processorFactory);
- }
-
- @Override
- public ModelineFactory getModelineFactory() {
- return getExtendedCamelContext().getModelineFactory();
- }
-
- @Override
- public void setModelineFactory(ModelineFactory modelineFactory) {
- getExtendedCamelContext().setModelineFactory(modelineFactory);
- }
-
- @Override
- public InternalProcessorFactory getInternalProcessorFactory() {
- return getExtendedCamelContext().getInternalProcessorFactory();
- }
-
- @Override
- public void setInternalProcessorFactory(InternalProcessorFactory internalProcessorFactory) {
- getExtendedCamelContext().setInternalProcessorFactory(internalProcessorFactory);
- }
-
- @Override
- public InterceptEndpointFactory getInterceptEndpointFactory() {
- return getExtendedCamelContext().getInterceptEndpointFactory();
- }
-
- @Override
- public void setInterceptEndpointFactory(InterceptEndpointFactory interceptEndpointFactory) {
- getExtendedCamelContext().setInterceptEndpointFactory(interceptEndpointFactory);
- }
-
- @Override
- public RouteFactory getRouteFactory() {
- return getExtendedCamelContext().getRouteFactory();
- }
-
- @Override
- public void setRouteFactory(RouteFactory routeFactory) {
- getExtendedCamelContext().setRouteFactory(routeFactory);
- }
-
- @Override
- public ModelJAXBContextFactory getModelJAXBContextFactory() {
- return getExtendedCamelContext().getModelJAXBContextFactory();
- }
-
- @Override
- public void setModelJAXBContextFactory(ModelJAXBContextFactory modelJAXBContextFactory) {
- getExtendedCamelContext().setModelJAXBContextFactory(modelJAXBContextFactory);
- }
-
- @Override
- public DeferServiceFactory getDeferServiceFactory() {
- return getExtendedCamelContext().getDeferServiceFactory();
- }
-
- @Override
- public void setDeferServiceFactory(DeferServiceFactory deferServiceFactory) {
- getExtendedCamelContext().setDeferServiceFactory(deferServiceFactory);
- }
-
- @Override
- public UnitOfWorkFactory getUnitOfWorkFactory() {
- return getExtendedCamelContext().getUnitOfWorkFactory();
- }
-
- @Override
- public void setUnitOfWorkFactory(UnitOfWorkFactory unitOfWorkFactory) {
- getExtendedCamelContext().setUnitOfWorkFactory(unitOfWorkFactory);
- }
-
- @Override
- public AnnotationBasedProcessorFactory getAnnotationBasedProcessorFactory() {
- return getExtendedCamelContext().getAnnotationBasedProcessorFactory();
- }
-
- @Override
- public void setAnnotationBasedProcessorFactory(AnnotationBasedProcessorFactory annotationBasedProcessorFactory) {
- getExtendedCamelContext().setAnnotationBasedProcessorFactory(annotationBasedProcessorFactory);
- }
-
- @Override
- public BeanProxyFactory getBeanProxyFactory() {
- return getExtendedCamelContext().getBeanProxyFactory();
- }
-
- @Override
- public BeanProcessorFactory getBeanProcessorFactory() {
- return getExtendedCamelContext().getBeanProcessorFactory();
- }
-
- @Override
- public ScheduledExecutorService getErrorHandlerExecutorService() {
- return getExtendedCamelContext().getErrorHandlerExecutorService();
- }
-
- @Override
- public void addInterceptStrategy(InterceptStrategy interceptStrategy) {
- getExtendedCamelContext().addInterceptStrategy(interceptStrategy);
- }
-
- @Override
- public List<InterceptStrategy> getInterceptStrategies() {
- return getExtendedCamelContext().getInterceptStrategies();
- }
-
- @Override
- public void setupManagement(Map<String, Object> options) {
- getExtendedCamelContext().setupManagement(options);
- }
-
- @Override
- public Set<LogListener> getLogListeners() {
- return getExtendedCamelContext().getLogListeners();
- }
-
- @Override
- public void addLogListener(LogListener listener) {
- getExtendedCamelContext().addLogListener(listener);
- }
-
- @Override
- public AsyncProcessorAwaitManager getAsyncProcessorAwaitManager() {
- return getExtendedCamelContext().getAsyncProcessorAwaitManager();
- }
-
- @Override
- public void setAsyncProcessorAwaitManager(AsyncProcessorAwaitManager manager) {
- getExtendedCamelContext().setAsyncProcessorAwaitManager(manager);
- }
-
- @Override
- public BeanIntrospection getBeanIntrospection() {
- return getExtendedCamelContext().getBeanIntrospection();
- }
-
- @Override
- public void setBeanIntrospection(BeanIntrospection beanIntrospection) {
- getExtendedCamelContext().setBeanIntrospection(beanIntrospection);
- }
-
- @Override
- public HeadersMapFactory getHeadersMapFactory() {
- return getExtendedCamelContext().getHeadersMapFactory();
- }
-
- @Override
- public void setHeadersMapFactory(HeadersMapFactory factory) {
- getExtendedCamelContext().setHeadersMapFactory(factory);
- }
-
- @Override
- public ExchangeFactory getExchangeFactory() {
- return getExtendedCamelContext().getExchangeFactory();
- }
-
- @Override
- public void setExchangeFactory(ExchangeFactory exchangeFactory) {
- getExtendedCamelContext().setExchangeFactory(exchangeFactory);
- }
-
- @Override
- public ExchangeFactoryManager getExchangeFactoryManager() {
- return getExtendedCamelContext().getExchangeFactoryManager();
- }
-
- @Override
- public void setExchangeFactoryManager(ExchangeFactoryManager exchangeFactoryManager) {
- getExtendedCamelContext().setExchangeFactoryManager(exchangeFactoryManager);
- }
-
- @Override
- public ProcessorExchangeFactory getProcessorExchangeFactory() {
- return getExtendedCamelContext().getProcessorExchangeFactory();
- }
-
- @Override
- public void setProcessorExchangeFactory(ProcessorExchangeFactory processorExchangeFactory) {
- getExtendedCamelContext().setProcessorExchangeFactory(processorExchangeFactory);
- }
-
- @Override
- public ReactiveExecutor getReactiveExecutor() {
- return getExtendedCamelContext().getReactiveExecutor();
- }
-
- @Override
- public void setReactiveExecutor(ReactiveExecutor reactiveExecutor) {
- getExtendedCamelContext().setReactiveExecutor(reactiveExecutor);
- }
-
- @Override
- public boolean isEventNotificationApplicable() {
- return getExtendedCamelContext().isEventNotificationApplicable();
- }
-
- @Override
- public void setEventNotificationApplicable(boolean eventNotificationApplicable) {
- getExtendedCamelContext().setEventNotificationApplicable(eventNotificationApplicable);
- }
-
- @Override
- public void setRoutesLoader(RoutesLoader routesLoader) {
- getExtendedCamelContext().setRoutesLoader(routesLoader);
- }
-
- @Override
- public RoutesLoader getRoutesLoader() {
- return getExtendedCamelContext().getRoutesLoader();
- }
-
- @Override
- public ResourceLoader getResourceLoader() {
- return getExtendedCamelContext().getResourceLoader();
- }
-
- @Override
- public void setResourceLoader(ResourceLoader resourceLoader) {
- getExtendedCamelContext().setResourceLoader(resourceLoader);
- }
-
- @Override
- public void setModelToXMLDumper(ModelToXMLDumper modelToXMLDumper) {
- getExtendedCamelContext().setModelToXMLDumper(modelToXMLDumper);
- }
-
- @Override
- public ModelToXMLDumper getModelToXMLDumper() {
- return getExtendedCamelContext().getModelToXMLDumper();
- }
-
- @Override
- public void setRestBindingJaxbDataFormatFactory(RestBindingJaxbDataFormatFactory restBindingJaxbDataFormatFactory) {
- getExtendedCamelContext().setRestBindingJaxbDataFormatFactory(restBindingJaxbDataFormatFactory);
- }
-
- @Override
- public RestBindingJaxbDataFormatFactory getRestBindingJaxbDataFormatFactory() {
- return getExtendedCamelContext().getRestBindingJaxbDataFormatFactory();
- }
-
- @Override
- public RuntimeCamelCatalog getRuntimeCamelCatalog() {
- return getExtendedCamelContext().getRuntimeCamelCatalog();
- }
-
- @Override
- public void setRuntimeCamelCatalog(RuntimeCamelCatalog runtimeCamelCatalog) {
- getExtendedCamelContext().setRuntimeCamelCatalog(runtimeCamelCatalog);
- }
-
- @Override
- public ConfigurerResolver getConfigurerResolver() {
- return getExtendedCamelContext().getConfigurerResolver();
- }
-
- @Override
- public void setConfigurerResolver(ConfigurerResolver configurerResolver) {
- getExtendedCamelContext().setConfigurerResolver(configurerResolver);
- }
-
- @Override
- public UriFactoryResolver getUriFactoryResolver() {
- return getExtendedCamelContext().getUriFactoryResolver();
- }
-
- @Override
- public void setUriFactoryResolver(UriFactoryResolver uriFactoryResolver) {
- getExtendedCamelContext().setUriFactoryResolver(uriFactoryResolver);
- }
-
- @Override
- public RouteController getInternalRouteController() {
- return getExtendedCamelContext().getInternalRouteController();
- }
-
- @Override
- public EndpointUriFactory getEndpointUriFactory(String scheme) {
- return getExtendedCamelContext().getEndpointUriFactory(scheme);
- }
-
- @Override
- public void addRoute(Route route) {
- getExtendedCamelContext().addRoute(route);
- }
-
- @Override
- public void removeRoute(Route route) {
- getExtendedCamelContext().removeRoute(route);
- }
-
- @Override
- public Processor createErrorHandler(Route route, Processor processor) throws Exception {
- return getExtendedCamelContext().createErrorHandler(route, processor);
- }
-
- @Override
- public void setLightweight(boolean lightweight) {
- getExtendedCamelContext().setLightweight(lightweight);
- }
-
- @Override
- public boolean isLightweight() {
- return getExtendedCamelContext().isLightweight();
- }
-
- @Override
- public StartupStepRecorder getStartupStepRecorder() {
- return getExtendedCamelContext().getStartupStepRecorder();
- }
-
- @Override
- public void setStartupStepRecorder(StartupStepRecorder startupStepRecorder) {
- getExtendedCamelContext().setStartupStepRecorder(startupStepRecorder);
- }
-
- @Override
- public CliConnectorFactory getCliConnectorFactory() {
- return getExtendedCamelContext().getCliConnectorFactory();
- }
-
- @Override
- public void setCliConnectorFactory(CliConnectorFactory cliConnectorFactory) {
- getExtendedCamelContext().setCliConnectorFactory(cliConnectorFactory);
- }
-
- @Override
- public String getTestExcludeRoutes() {
- return getExtendedCamelContext().getTestExcludeRoutes();
- }
-
//
// CatalogCamelContext
//
@@ -2124,27 +1450,6 @@ public class LightweightCamelContext implements CamelContext, ExtendedCamelConte
return getModelCamelContext().getModelReifierFactory();
}
- @Override
- public PeriodTaskScheduler getPeriodTaskScheduler() {
- return getExtendedCamelContext().getPeriodTaskScheduler();
- }
-
- @Override
- public void setPeriodTaskScheduler(PeriodTaskScheduler periodTaskScheduler) {
- getExtendedCamelContext().setPeriodTaskScheduler(periodTaskScheduler);
-
- }
-
- @Override
- public PeriodTaskResolver getPeriodTaskResolver() {
- return getExtendedCamelContext().getPeriodTaskResolver();
- }
-
- @Override
- public void setPeriodTaskResolver(PeriodTaskResolver periodTaskResolver) {
- getExtendedCamelContext().setPeriodTaskResolver(periodTaskResolver);
- }
-
@Override
public void setModelReifierFactory(ModelReifierFactory modelReifierFactory) {
getModelCamelContext().setModelReifierFactory(modelReifierFactory);
diff --git a/core/camel-core/src/test/java/org/apache/camel/ContextTestSupport.java b/core/camel-core/src/test/java/org/apache/camel/ContextTestSupport.java
index 07d4b885084..d12d63fa565 100644
--- a/core/camel-core/src/test/java/org/apache/camel/ContextTestSupport.java
+++ b/core/camel-core/src/test/java/org/apache/camel/ContextTestSupport.java
@@ -201,8 +201,7 @@ public abstract class ContextTestSupport extends TestSupport {
protected CamelContext createCamelContext() throws Exception {
CamelContext context;
if (useLightweightContext) {
- LightweightCamelContext ctx = new LightweightCamelContext();
- ctx.setRegistry(createRegistry());
+ LightweightCamelContext ctx = new LightweightCamelContext(createRegistry());
context = ctx;
} else {
DefaultCamelContext ctx = new DefaultCamelContext(true);