in resume-api/resume-api-fileset-clusterized/src/main/java/org/apache/camel/example/resume/fileset/clusterized/main/ClusterizedListener.java [46:61]
public void beforeConfigure(BaseMainSupport main) {
try {
LOG.trace("Adding the cluster service");
main.getCamelContext().addService(clusterService);
LOG.trace("Creating the strategy");
LOG.trace("Creating the route");
RouteBuilder routeBuilder = new ClusterizedLargeDirectoryRouteBuilder();
main.getCamelContext().addRoutes(routeBuilder);
} catch (Exception e) {
LOG.error("Unable to add the cluster service: {}", e.getMessage(), e);
System.exit(1);
}
}