@Activate public void activate(BundleContext context, CamelConfig config) throws Exception { this.camelContext = new OsgiDefaultCamelContext(context, new OsgiServiceRegistry(context)); this.camelContext.start(); this.camelreactive = CamelReactiveStreams.get(camelContext); }