Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (athena.apache.org: domain of claus.ibsen@gmail.com
 designates 209.85.217.173 as permitted sender)
MIME-Version: 1.0
In-Reply-To: <1345914804494-5718059.post@n5.nabble.com>
References: <1345914804494-5718059.post@n5.nabble.com>
From: Claus Ibsen <claus.ibsen@gmail.com>
Date: Sun, 26 Aug 2012 09:14:08 +0200
Message-ID: 
 <CAGB5yN=5t3e4Hn2uELTaRAbsauq6u+FqzytVQtdB0G5xA6Y2Zw@mail.gmail.com>
Subject: Re: Periodic route activation use case
To: users@camel.apache.org
Content-Type: text/plain; charset=ISO-8859-1

On Sat, Aug 25, 2012 at 7:13 PM, Ashwin Pejavar
<ashwin.pejavar@gmail.com> wrote:
> I have a use-case where I need to consume files at a fixed cron schedule.
>
> For example, I need my input route to resume everyday at 6AM, process all
> files collected in the input directory and go into suspension till 6AM the
> following day.
>
> I was hoping the CronScheduledRoutePolicy would be useful, but that doesn't
> quite do what I need. I can use it to start the route at 6AM, but there
> seems to be no way of automatically suspending it when all the files are
> processed.
>
> Is there a way of doing this in Camel?
>

See this FAQ
http://camel.apache.org/how-can-i-stop-a-route-from-a-route.html

You could possible either extend the cron scheduled route policy, and
add logic in the onExchangeDone and figure out if its the last
exchange from the file batch. And then if so stop/suspend the
consumer. The file consumer is cheap to suspend as its an internal
flag that indicate its suspended (AFAIR). And therefore you most
likely wont need to use a separate thread as the FAQ tells to do.

The file consumer will set a property on the exchange when there is no
more files (eg the batch is complete)
 exchange.setProperty(Exchange.BATCH_COMPLETE, true);

So you can check for that property, and know when you are done, and
can suspend the consumer.
Something a like

onExchangeDone(Route route, Exchange exchange) {
  // check for batch complete
  if (...) {
      // stop will favor suspend over stopping, so its fine to invoke
this method
     stopConsumer(route.getConsumer());
  }
}

And on the file component you would need to enable the
sendEmptyMessageWhenIdle=true option to send an empty message if there
is no files. So the routing will kick in. You would need to cater for
an empty message in your route logic though.


A total different approach would be to use a custom
PollingConsumerPollStrategy on the file endpoint.
http://camel.apache.org/polling-consumer.html

It has callbacks when the polling starts / commits. And the number of
polled messages (eg number of files found).
You can then use that to implement logic to suspend the consumer in
the commit method.

That may be an easier task to try out at first. Extending the
DefaultPollingConsumerPollStrategy and override the commit method.


>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Periodic-route-activation-use-case-tp5718059.html
> Sent from the Camel - Users mailing list archive at Nabble.com.


-- 
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen