Default Camel Context unable to find installed camel-jetty component, when deployed as a bundle on JBoss Fuse

Solution Verified - Updated -

Environment

  • Red Hat JBoss Fuse
    • 6.2.0

Issue

  • I have a bean defined in a blueprint project. In the constructor of that bean I would like to create new Camel Contexts. I do it by defining a new DefaultCamelContext like:
CamelContext camelContext = new DefaultCamelContext();
        try {
            camelContext.setTracing(true);
            camelContext.start();
        } catch (Exception e) {
        }
  • However if I add in it a route that uses jetty like- form("jetty:....") , got the following exception in the logs:
org.apache.camel.FailedToCreateRouteException: Failed to create route TestRoute: Route(TestRoute)[[From[jetty:http://10.10.10.10:8080/myTestSe... because of Failed to resolve endpoint: jetty://http://10.10.10.10:8080/myTestServlet/myServlet due to: No component found with scheme: jetty

  at org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:190)

  at org.apache.camel.impl.DefaultCamelContext.startRoute(DefaultCamelContext.java:841)[org.apache.camel:camel-core:2.15.1.redhat-620133 com.googlecode.concurrentlinkedhashmap:concurrentlinkedhashmap-lru:1.4.2]
  at org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:2895)[org.apache.camel:camel-core:2.15.1.redhat-620133 com.googlecode.concurrentlinkedhashmap:concurrentlinkedhashmap-lru:1.4.2]
  at org.apache.camel.impl.DefaultCamelContext.addRouteDefinitions(DefaultCamelContext.java:775)[org.apache.camel:camel-core:2.15.1.redhat-620133 com.googlecode.concurrentlinkedhashmap:concurrentlinkedhashmap-lru:1.4.2]

  at org.apache.camel.builder.RouteBuilder.populateRoutes(RouteBuilder.java:397)

  at org.apache.camel.builder.RouteBuilder.addRoutesToCamelContext(RouteBuilder.java:311)

  at org.apache.camel.impl.DefaultCamelContext$1.call(DefaultCamelContext.java:731)

  at org.apache.camel.impl.DefaultCamelContext$1.call(DefaultCamelContext.java:728)

  at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:2486)[org.apache.camel:camel-core:2.15.1.redhat-620133 com.googlecode.concurrentlinkedhashmap:concurrentlinkedhashmap-lru:1.4.2]
  at org.apache.camel.impl.DefaultCamelContext.addRoutes(DefaultCamelContext.java:728)[org.apache.camel:camel-core:2.15.1.redhat-620133 com.googlecode.concurrentlinkedhashmap:concurrentlinkedhashmap-lru:1.4.2]

  at com.wirecard.conductor.bean.InitialBean.(InitialBean.java:66)

  at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)[:1.7.0_79]

  at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)[:1.7.0_79]
  at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)[:1.7.0_79]
  at java.lang.reflect.Constructor.newInstance(Constructor.java:526)[:1.7.0_79]
  at org.apache.aries.blueprint.utils.ReflectionUtils.newInstance(ReflectionUtils.java:329)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at org.apache.aries.blueprint.container.BeanRecipe.newInstance(BeanRecipe.java:962)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at org.apache.aries.blueprint.container.BeanRecipe.getInstance(BeanRecipe.java:331)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at org.apache.aries.blueprint.container.BeanRecipe.internalCreate2(BeanRecipe.java:806)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at org.apache.aries.blueprint.container.BeanRecipe.internalCreate(BeanRecipe.java:787)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at org.apache.aries.blueprint.di.AbstractRecipe$1.call(AbstractRecipe.java:79)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at java.util.concurrent.FutureTask.run(FutureTask.java:262)[:1.7.0_79]
  at org.apache.aries.blueprint.di.AbstractRecipe.create(AbstractRecipe.java:88)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at org.apache.aries.blueprint.container.BlueprintRepository.createInstances(BlueprintRepository.java:245)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at org.apache.aries.blueprint.container.BlueprintRepository.createAll(BlueprintRepository.java:183)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at org.apache.aries.blueprint.container.BlueprintContainerImpl.instantiateEagerComponents(BlueprintContainerImpl.java:682)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at org.apache.aries.blueprint.container.BlueprintContainerImpl.doRun(BlueprintContainerImpl.java:377)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at org.apache.aries.blueprint.container.BlueprintContainerImpl.run(BlueprintContainerImpl.java:269)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)[:1.7.0_79]
  at java.util.concurrent.FutureTask.run(FutureTask.java:262)[:1.7.0_79]
  at org.apache.aries.blueprint.container.ExecutorServiceWrapper.run(ExecutorServiceWrapper.java:106)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at org.apache.aries.blueprint.utils.threading.impl.DiscardableRunnable.run(DiscardableRunnable.java:48)[org.apache.aries.blueprint:org.apache.aries.blueprint.core:1.4.2]
  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)[:1.7.0_79]
  at java.util.concurrent.FutureTask.run(FutureTask.java:262)[:1.7.0_79]
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)[:1.7.0_79]
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)[:1.7.0_79]
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_79]
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_79]
  at java.lang.Thread.run(Thread.java:745)[:1.7.0_79]

Resolution

  • Use OsgiDefaultCamelContext instead of DefaultCamelContext. So the container can manage the camel context as it manages the bundle. Like below
    private CamelContext camelContext = null;

    public void start(BundleContext bundleContext) throws Exception {
        camelContext = new OsgiDefaultCamelContext(bundleContext);
        camelContext.addRoutes(new RouteBuilder() {
            public void configure() {
                from("jetty:http://localhost:8182/mytestservice").log("Processing ${body}");
            }
        });

        camelContext.start();
    }
  • camel-core-osgi dependency will also be require to provide the OsgiDefaultCamelContext class.

This solution is part of Red Hat’s fast-track publication program, providing a huge library of solutions that Red Hat engineers have created while supporting our customers. To give you the knowledge you need the instant it becomes available, these articles may be presented in a raw and unedited form.

Close

Welcome! Check out the Getting Started with Red Hat page for quick tours and guides for common tasks.