Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (nike.apache.org: domain of willem.jiang@gmail.com
 designates 209.85.210.49 as permitted sender)
Message-ID: <4E374CD5.7040200@gmail.com>
Date: Tue, 02 Aug 2011 09:03:17 +0800
From: Willem Jiang <willem.jiang@gmail.com>
User-Agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10.7;
 rv:5.0) Gecko/20110624 Thunderbird/5.0
MIME-Version: 1.0
To: users@camel.apache.org
Subject: Re: Route does not shut down if there is no message on poll.
References: <1311960633885-476108.post@n5.nabble.com>
 <AANLkTikW8FFmF_y0wlL205-yDOSy9G2-1nEYBLSi69xf@mail.gmail.com>
 <AANLkTik4jrH3ht0PrKvlZpM4H9MIuwG2cajiN2cbGmNl@mail.gmail.com>
 <1311960633884-476111.post@n5.nabble.com>
 <1311960633883-4647763.post@n5.nabble.com>
 <CAGB5yNkRCK-hKpQ=+D37-AQtLJ58cfZ1D8Ts=9GMDQdTeuy9bg@mail.gmail.com>
 <1312198431307-4654806.post@n5.nabble.com>
In-Reply-To: <1312198431307-4654806.post@n5.nabble.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: 7bit

Hi,

Can you check the timedroute route states ?
CronScheduledRoutePolicy  start or resume the route when the route 
status is ready.

     ServiceStatus routeStatus = 
route.getRouteContext().getCamelContext().getRouteStatus(route.getId());
         if (action == Action.START) {
             if (routeStatus == ServiceStatus.Stopped) {
                 startRoute(route);
             } else if (routeStatus == ServiceStatus.Suspended) {
                 startConsumer(route.getConsumer());
             }
         }

Willem

On 8/1/11 7:33 PM, cwhistler wrote:
> I think I have this worked out now.  I found the PollingConsumerPollStrategy
> interface so I created an EmptyPollStrategy class.  I changed the begin()
> method to simply return true.  In the commit() method I checked the
> numberPolled parameter and if it is 0 then I just stop the consumer.  I left
> the rollback() method unchanged.
>
> public boolean begin(Consumer consumer, Endpoint endpoint)
> {
>      return true;
> }
>
> public void commit(Consumer consumer, Endpoint endpoint, int numberPolled)
> {
>      if (numberPolled == 0)
>      {
> 	try
> 	{
> 		consumer.stop();
> 	}
> 	catch(Exception e)
> 	{
> 		e.printStackTrace();
> 	}
>      }
> }
>
> public boolean rollback(Consumer arg0, Endpoint arg1, int arg2, Exception
> arg3) throws Exception
> {
>      // TODO Auto-generated method stub
>      return false;
> }
>
>
> OK so to run my route only at 9:35 every day I have setup the route as
> follows.  The references to the filters and processors are all wired up with
> Spring.
>
> I created the StopRouteProcessor to stop the route when it has read all of
> the files that were initially polled.
>
> The .noAutoStartup() seemed to be required as the route always started with
> camel and then at the scheduled time.
>
> CronScheduledRoutePolicy policy = new CronScheduledRoutePolicy();
> policy.setRouteStartTime("0 35 9 * * ?");
> 		
> from("file://test/input?preMove=inprogress&pollStrategy=#emptyPollStrategy&delete=true&filter=#errorFileFilter")
>      .routePolicy(policy)
>      .noAutoStartup()
>      .routeId("timedroute")
>      .processRef("addHeadersProcessor")
>      .to("file://test/output")
>      .onCompletion().process(new StopRouteProcessor("timedroute").end()
> ;
>
> The only problem I'm seeing now is when I have to schedule this route to run
> more than once.  So for example I want 9:35 and then again at 11:35.  By
> letting Spring wire up the EmptyPollStrategy, it is only effective with the
> first scheduled execution.  It never runs on the 2nd schedule.
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Route-does-not-shut-down-if-there-is-no-message-on-poll-tp476108p4654806.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>


-- 
Willem
----------------------------------
FuseSource
Web: http://www.fusesource.com
Blog:    http://willemjiang.blogspot.com (English)
          http://jnn.javaeye.com (Chinese)
Twitter: willemjiang
Weibo: willemjiang