camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bonnahu <bonn...@gmail.com>
Subject Why cannot do a graceful shutdown?
Date Sun, 21 Jul 2013 14:29:59 GMT
Hey guys,
I need to shutdown the camelcontext in a Processor. Here is what I am doing:

<bean id="downloadLogger" class="camelinaction.DownloadLogger"/>
<camelContext id="testingContext" 
xmlns="http://camel.apache.org/schema/spring">
   
    <route>
      <from uri="file:src/data?noop=true"/>
      <filter>
      <xpath>/order[@test]</xpath>
      <process ref="downloadLogger"/>
      <to uri="jms:incomingOrders"/>
      </filter>
    </route>
  </camelContext>

Here is the DownloadLogger Processor:

public class DownloadLogger implements Processor {
    
	//private Logger log = new Logger(DownloadLogger.class);
	public void process(Exchange exchange) throws Exception {
    	System.out.println("We just downloaded:  " 
                + exchange.getIn().getHeader("CamelFileName"));
    	System.out.println("before camel context stop");
    	/exchange.getContext().getShutdownStrategy().setTimeout(5);
    	exchange.getContext().stop();/
    	System.out.println("after camel context stop");
    }
}


When I run it, I got the following information. Can someone tell me why I
can't perform a graceful shutdown 
here?


[                          main] MainSupport                    INFO  Apache
Camel 2.11.0 starting
[                          main] SpringCamelContext             INFO  Apache
Camel 2.11.0 (CamelContext: testingContext) is starting
[                          main] ManagementStrategyFactory      INFO  JMX
enabled.
[                          main] DefaultTypeConverter           INFO  Loaded
175 type converters
[                          main] FileEndpoint                   INFO 
Endpoint is configured with noop=true so forcing endpoint to be idempotent
as well
[                          main] FileEndpoint                   INFO  Using
default memory based idempotent repository with cache max size: 1000
[                          main] XPathBuilder                   INFO 
Created default XPathFactory
com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@31e4c806
[                          main] SpringCamelContext             INFO  Route:
route1 started and consuming from: Endpoint[file://src/data?noop=true]
[                          main] ultManagementLifecycleStrategy INFO  Load
performance statistics enabled.
[                          main] SpringCamelContext             INFO  Total
1 routes, of which 1 is started.
[                          main] SpringCamelContext             INFO  Apache
Camel 2.11.0 (CamelContext: testingContext) started in 0.431 seconds
[t) thread #0 - file://src/data] rFileExclusiveReadLockStrategy WARN 
Deleting orphaned lock file: src\data\message1.xml.camelLock
We just downloaded:  message1.xml
before camel context stop
[t) thread #0 - file://src/data] SpringCamelContext             INFO  Apache
Camel 2.11.0 (CamelContext: testingContext) is shutting down
*[t) thread #0 - file://src/data] DefaultShutdownStrategy        INFO 
Starting to graceful shutdown 1 routes (timeout 5 seconds)
[text) thread #2 - ShutdownTask] DefaultShutdownStrategy        INFO 
Waiting as there are still 2 inflight and pending exchanges to complete,
timeout in 5 seconds.
[text) thread #2 - ShutdownTask] DefaultShutdownStrategy        INFO 
Waiting as there are still 2 inflight and pending exchanges to complete,
timeout in 4 seconds.
[text) thread #2 - ShutdownTask] DefaultShutdownStrategy        INFO 
Waiting as there are still 2 inflight and pending exchanges to complete,
timeout in 3 seconds.
[text) thread #2 - ShutdownTask] DefaultShutdownStrategy        INFO 
Waiting as there are still 2 inflight and pending exchanges to complete,
timeout in 2 seconds.
[text) thread #2 - ShutdownTask] DefaultShutdownStrategy        INFO 
Waiting as there are still 2 inflight and pending exchanges to complete,
timeout in 1 seconds.
[t) thread #0 - file://src/data] DefaultShutdownStrategy        WARN 
Timeout occurred. Now forcing the routes to be shutdown now.
[text) thread #2 - ShutdownTask] DefaultShutdownStrategy        WARN 
Interrupted while waiting during graceful shutdown, will force shutdown
now.*
[text) thread #2 - ShutdownTask] DefaultShutdownStrategy        INFO  Route:
route1 shutdown complete, was consuming from:
Endpoint[file://src/data?noop=true]
[t) thread #0 - file://src/data] DefaultShutdownStrategy        INFO 
Graceful shutdown of 1 routes completed in 5 seconds
[t) thread #0 - file://src/data] DefaultInflightRepository      WARN 
Shutting down while there are still 1 in flight exchanges.
[t) thread #0 - file://src/data] SpringCamelContext             INFO  Uptime
6.521 seconds
[t) thread #0 - file://src/data] SpringCamelContext             INFO  Apache
Camel 2.11.0 (CamelContext: testingContext) is shutdown in 5.016 seconds
after camel context stop
[t) thread #0 - file://src/data] GenericFileOnCompletion        WARN 
Rollback file strategy:
org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@2d57f820
for file: GenericFile[message1.xml]





--
View this message in context: http://camel.465427.n5.nabble.com/Why-cannot-do-a-graceful-shutdown-tp5735962.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message