{"type":"doc","content":[{"type":"paragraph","content":[{"text":"Regarding startup and shutdown of routes, by default, the routes are automatically started when your Apache Camel application (ie. the ","type":"text"},{"text":"CamelContext","type":"text","marks":[{"type":"code"}]},{"text":" instance) starts up. Consequently, these same routes are automatically shut down when your Apache Camel application stops.","type":"text"}]},{"type":"paragraph","content":[{"text":"For most of our non-critical deployments, the granular details of the shutdown process is usually not very important. However, in a production environment, in order to avoid data loss it is often crucial that existing tasks should run to completion during the shutdown process. ","type":"text"}]},{"type":"paragraph","content":[{"text":"Also, as another consideration, we typically want to control the order in which routes shut down so that dependencies between different routes and processes are not violated (which would prevent existing tasks from running to completion).","type":"text"}]},{"type":"paragraph","content":[{"text":"For this reason, Apache Camel provides a set of features to support ","type":"text"},{"text":"graceful shutdown","type":"text","marks":[{"type":"em"}]},{"text":" of applications. Graceful shutdown gives you full control over the stopping and starting of routes, enabling you to control the shutdown order of routes and enabling current tasks to run to completion.","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Setting Route ID","type":"text"}]},{"type":"paragraph","content":[{"text":"It is a good best practice to assign a unique route ID to each of the routes that we build. This will make logging messages and management features more informative and easier to track. Additionally, the use of route IDs will provide greater control over the stopping and starting of routes.","type":"text"}]},{"type":"paragraph","content":[{"text":"Using the Java DSL, we can assign the route ID, ","type":"text"},{"text":"myProductRouteId","type":"text","marks":[{"type":"code"}]},{"text":", to a route by invoking the ","type":"text"},{"text":"routeId()","type":"text","marks":[{"type":"code"}]},{"text":" command as follows:","type":"text"}]},{"type":"codeBlock","content":[{"text":"from(\"SourceURI\").routeId(\"myProductRouteId\").process(...).to(TargetURI);","type":"text"}]},{"type":"paragraph","content":[{"text":"In the XML DSL, we can do the same things as follows:","type":"text"}]},{"type":"codeBlock","content":[{"text":"\n \n \n \n \n \n","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Manually Start and Stop Routes","type":"text"}]},{"type":"paragraph","content":[{"text":"There may be a need for us to manually start or stop a route at any time. We can perform this in Java by invoking the ","type":"text"},{"text":"startRoute()","type":"text","marks":[{"type":"code"}]},{"text":" and ","type":"text"},{"text":"stopRoute()","type":"text","marks":[{"type":"code"}]},{"text":" methods on the ","type":"text"},{"text":"CamelContext","type":"text","marks":[{"type":"code"}]},{"text":" instance. For example, to start the route having the route ID, ","type":"text"},{"text":"notAuto","type":"text","marks":[{"type":"code"}]},{"text":", invoke the ","type":"text"},{"text":"startRoute()","type":"text","marks":[{"type":"code"}]},{"text":" method on the ","type":"text"},{"text":"CamelContext","type":"text","marks":[{"type":"code"}]},{"text":" instance, ","type":"text"},{"text":"context","type":"text","marks":[{"type":"code"}]},{"text":":","type":"text"}]},{"type":"codeBlock","content":[{"text":"context.startRoute(\"notAuto\");","type":"text"}]},{"type":"paragraph","content":[{"text":"To stop the route ","type":"text"},{"text":"notAuto","type":"text","marks":[{"type":"code"}]},{"text":", we can invoke the ","type":"text"},{"text":"stopRoute()","type":"text","marks":[{"type":"code"}]},{"text":" method on our instance:","type":"text"}]},{"type":"codeBlock","content":[{"text":"context.stopRoute(\"nonAuto\");","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Startup Order","type":"text"}]},{"type":"paragraph","content":[{"text":"By default, Apache Camel starts up routes in a non-deterministic order. However, in some application situations, it could be vital to control the order of the route startup. Each route must be assigned a ","type":"text"},{"text":"unique","type":"text","marks":[{"type":"strong"}]},{"text":" startup order value. You can choose any positive integer value that is less than 1000","type":"text"}]},{"type":"paragraph","content":[{"text":"To control the startup order, we can use startupOrder() command in the Java DSL. It will accept a positive integer value as its argument and the route with the lowest integer value starts first:","type":"text"}]},{"type":"codeBlock","content":[{"text":"from(\"jetty:http://fooserver:8080\")\n .routeId(\"one\")\n .startupOrder(2)\n .to(\"seda:buffer\");\n\nfrom(\"seda:buffer\")\n .routeId(\"two\")\n .startupOrder(1)\n .to(\"mock:result\");\n\n// This route's startup order is unspecified\nfrom(\"jms:queue:foo\").to(\"jms:queue:bar\");","type":"text"}]},{"type":"paragraph","content":[{"text":"NOTE","type":"text","marks":[{"type":"strong"}]},{"text":": These two routes are linked together via the endpoint of ","type":"text"},{"text":"seda:buffer","type":"text","marks":[{"type":"code"}]},{"text":". we can guarantee that the first route segment starts ","type":"text"},{"text":"after","type":"text","marks":[{"type":"strong"}]},{"text":" the second route segment by using the startup orders (2 and 1 respectively)","type":"text"}]},{"type":"paragraph","content":[{"text":"Or in Spring XML:","type":"text"}]},{"type":"codeBlock","content":[{"text":"\n \n \n\n\n\n \n \n\n\n\n\n \n \n","type":"text"}]},{"type":"paragraph","content":[{"text":"NOTE: ","type":"text","marks":[{"type":"strong"}]},{"text":"Each route must be assigned a ","type":"text"},{"text":"unique","type":"text","marks":[{"type":"strong"}]},{"text":" startup order value. You can choose any positive integer value that is less than 1000","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Shutdown Order","type":"text"}]},{"type":"paragraph","content":[{"text":"When we our instance is shutting down, Apache Camel controls the shutdown sequence using a pluggable ","type":"text"},{"text":"shutdown strategy","type":"text","marks":[{"type":"em"}]},{"text":". This strategy implements the following shutdown sequence:","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"All Routes are shut down in the ","type":"text"},{"text":"reverse","type":"text","marks":[{"type":"strong"}]},{"text":" of the start-up order.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"In normal situations, the shutdown strategy waits until the currently active exchanges have finished processing. ","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Shutdown sequence is bound by a timeout (default of 300 seconds). If the shutdown sequence exceeds this timeout, the shutdown strategy will force shutdown to occur, even if some tasks are still running.","type":"text"}]}]}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Shutdown Sequence of Routes","type":"text"}]},{"type":"paragraph","content":[{"text":"By default our routes are shut down in the reverse sequence of the start-up order. That is, when a start-up order is defined using the ","type":"text"},{"text":"startupOrder()","type":"text","marks":[{"type":"code"}]},{"text":" command (in Java DSL) or ","type":"text"},{"text":"startupOrder","type":"text","marks":[{"type":"code"}]},{"text":" attribute (in XML DSL), the first route to shut down is the route with the ","type":"text"},{"text":"highest","type":"text","marks":[{"type":"strong"}]},{"text":" integer value assigned by the start-up order.","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Shut Down Running Tasks","type":"text"}]},{"type":"paragraph","content":[{"text":"There may be situations where a route is still processing messages and if a route is still processing messages when the shutdown starts, the shutdown strategy normally waits until the currently active exchange has finished processing before shutting down the route. ","type":"text"}]},{"type":"paragraph","content":[{"text":"We are able to configure this behavior on each route using the ","type":"text"},{"text":"shutdownRunningTask","type":"text","marks":[{"type":"code"}]},{"text":" option. There are two possible options here: ","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"ShutdownRunningTask.CompleteCurrentTaskOnly","type":"text","marks":[{"type":"code"}]},{"text":"(Default)","type":"text","marks":[{"type":"strong"}]},{"text":" ","type":"text"}]}]}]},{"type":"paragraph","marks":[{"type":"indentation","attrs":{"level":1}}],"content":[{"text":"Usually, a route operates on just a single message at a time, so you can safely shut down the route after the current task has been completed.","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"ShutdownRunningTask.CompleteAllTasks","type":"text","marks":[{"type":"code"}]}]}]}]},{"type":"paragraph","marks":[{"type":"indentation","attrs":{"level":1}}],"content":[{"text":"We should specify this option in order to shut down situations where we have batch consumers processing. Some consumer endpoints (for example, File, FTP, Mail, iBATIS, and JPA) operate on a batch of messages at a time. For these types of endpoints, it is better to wait until all of the messages in the current batch have been completed.","type":"text"}]},{"type":"paragraph","content":[{"text":"To shut down a File consumer endpoint gracefully, you should specify the ","type":"text"},{"text":"CompleteAllTasks","type":"text","marks":[{"type":"code"}]},{"text":" option in the Java DSL as below:","type":"text"}]},{"type":"codeBlock","content":[{"text":"public void configure() throws Exception {\n from(\"file:target/pending\")\n .routeId(\"one\").startupOrder(2)\n .shutdownRunningTask(ShutdownRunningTask.CompleteAllTasks)\n .delay(1000).to(\"seda:foo\");\n\n from(\"seda:foo\")\n .routeId(\"two\").startupOrder(1)\n .to(\"mock:bar\");\n}","type":"text"}]},{"type":"paragraph","content":[{"text":"Or, in the XML DSL:","type":"text"}]},{"type":"codeBlock","content":[{"text":"\n \n \n 1000\n \n ","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Shutdown Timeout","type":"text"}]},{"type":"paragraph","content":[{"text":"As mentioned earlier, the shutdown timeout has a default value of 300 seconds. We can change the value of the timeout by invoking the ","type":"text"},{"text":"setTimeout()","type":"text","marks":[{"type":"code"}]},{"text":" method on the shutdown strategy. As an illustration, we can change the timeout value to 600 seconds:","type":"text"}]},{"type":"codeBlock","content":[{"text":"// context = CamelContext instance\ncontext.getShutdownStrategy().setTimeout(600);","type":"text"}]}],"version":1}

Browser not supported