protected DefaultCamelContext newCamelContext() { if (registry != null) { return new OsgiDefaultCamelContext(bundleContext, registry); } else { return new OsgiDefaultCamelContext(bundleContext); } }
@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); }
protected CamelContext createCamelContext() { return new OsgiDefaultCamelContext(bundleContext); }