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);
}