-
Bug
-
Resolution: Done
-
Major
-
2.10.0-fuse-71-047
-
None
-
None
using camel-quartz to start/stop routes in Fuse ESB 7.1 . They are using the following route
public class DebtorUpdatesToCreditManagerRouteBuilder extends RouteBuilder { private static final Logger LOG = LoggerFactory.getLogger(DebtorUpdatesToCreditManagerRouteBuilder.class); protected static final String ROUTE_ID = "started-and-stopped-route"; private static final int ALLOWED_GRACE_PERIOD_IN_MILLISECONDS = 100; private static final String START_ROUTE_SCHEDULE = "10 */1 * * * ? *"; private static final String STOP_ROUTE_SCHEDULE = "40 */1 * * * ? *"; private static final String CONSUMING_ENDPOINT = "jms:inputQueue"; @Override public void configure() { from(CONSUMING_ENDPOINT) .noAutoStartup() .routeId(ROUTE_ID) .routePolicy(startStopPolicy()) .log(LoggingLevel.DEBUG, ROUTE_ID, " ${body}") .process(aProcessor); } private CronScheduledRoutePolicy startStopPolicy() { final CronScheduledRoutePolicy result = new CronScheduledRoutePolicy(); LOG.info( String.format("Creating route with start schedule: '%s', and stop schedule '%s'", START_ROUTE_SCHEDULE, STOP_ROUTE_SCHEDULE) ); result.setRouteStartTime(START_ROUTE_SCHEDULE); result.setRouteStopTime(STOP_ROUTE_SCHEDULE); result.setRouteStopGracePeriod(ALLOWED_GRACE_PERIOD_IN_MILLISECONDS); result.setTimeUnit(TimeUnit.MILLISECONDS); return result; } private Processor aProcessor = new Processor() { @Override public void process(final Exchange exchange) throws Exception { LOG.info("Do something with [" + exchange + "]"); } }; }
The number of child services started seems to be increasing by one each time the route is started - I have taken an excert from the logs to illustrate
62-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting services on route: started-and-stopped-route 16:41:10,003 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> Instrumentation:route[DelegateAsync[RoutePolicy[[org.apache.camel.routepolicy.quartz.CronScheduledRoutePolicy@4f03a2d8]]]] 16:41:10,004 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> DelegateAsync[RoutePolicy[[org.apache.camel.routepolicy.quartz.CronScheduledRoutePolicy@4f03a2d8]]] 16:41:10,004 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> RoutePolicy[[org.apache.camel.routepolicy.quartz.CronScheduledRoutePolicy@4f03a2d8]] 16:41:10,004 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> UnitOfWork(RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[Pipeline[[Channel[Log(started-and-stopped-route)[ ${body}]], Channel[Wrap[com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22] -> com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22]]]]]]]]]]]]) 16:41:10,004 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[Pipeline[[Channel[Log(started-and-stopped-route)[ ${body}]], Channel[Wrap[com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22] -> com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22]]]]]]]]]]] 16:41:10,004 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[Pipeline[[Channel[Log(started-and-stopped-route)[ ${body}]], Channel[Wrap[com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22] -> com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22]]]]]]]]]] 16:41:10,004 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[Pipeline[[Channel[Log(started-and-stopped-route)[ ${body}]], Channel[Wrap[com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22] -> com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22]]]]]]]]] 16:41:10,004 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[Pipeline[[Channel[Log(started-and-stopped-route)[ ${body}]], Channel[Wrap[com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22] -> com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22]]]]]]]] 16:41:10,004 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[Pipeline[[Channel[Log(started-and-stopped-route)[ ${body}]], Channel[Wrap[com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22] -> com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22]]]]]]] 16:41:10,004 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> RouteContextProcessor[RouteContextProcessor[RouteContextProcessor[Pipeline[[Channel[Log(started-and-stopped-route)[ ${body}]], Channel[Wrap[com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22] -> com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22]]]]]] 16:41:10,004 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> RouteContextProcessor[RouteContextProcessor[Pipeline[[Channel[Log(started-and-stopped-route)[ ${body}]], Channel[Wrap[com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22] -> com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22]]]]] 16:41:10,005 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> RouteContextProcessor[Pipeline[[Channel[Log(started-and-stopped-route)[ ${body}]], Channel[Wrap[com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22] -> com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22]]]] 16:41:10,005 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> Pipeline[[Channel[Log(started-and-stopped-route)[ ${body}]], Channel[Wrap[com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22] -> com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22]]] 16:41:10,005 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> Channel[Log(started-and-stopped-route)[ ${body}]] 16:41:10,005 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> Log(started-and-stopped-route)[ ${body}] 16:41:10,008 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> Channel[Wrap[com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22] -> com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22] 16:41:10,008 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> Wrap[com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22] -> com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22 16:41:10,012 | DEBUG | DefaultQuartzScheduler-262-camel-3_Worker-8 | RouteService | 147 - org.apache.camel.camel-core - 2.10.0.fuse-71-047 | Starting child service on route: started-and-stopped-route -> com.acme.DebtorUpdatesToCreditManagerRouteBuilder$1@4d74bd22 16:41:10,021 | INFO | DefaultQuartzScheduler-262-camel-3_Worker-8 | OsgiSpringCamelContext