You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Chris Wolf <cw...@gmail.com> on 2013/05/17 18:53:42 UTC
How can I dynamically add or modify endpoints in a route?
I need to schedule multiple cron jobs in a route. The number and
schedules are not known at compile-time,
so I need to programatically configure the route at run-time. An
abbreviated version of my non-working
attempt is shown below. I created an anonymous RouteBuilder, in which
I created a route.
After, calling context.addRoutes(...), but before starting the
context, I want to programmatically
tweak the route definition, as shown by the "reconfigure(...)"
function, unfortunately any attempt
to lookup the route I just created fails - no routes found. Why? I
suspect that the route may actually
need to be started for it's initialization to complete, so should I
start it, then stop or suspend, then
programmatically modify?
BTW, I already checked my copy of "Camel In Action" and
http://camel.apache.org/faq.html but
no answers for me there....
context.addRoutes(new RouteBuilder() {
public void configure() {
from("quartz://demo-1/{{custId}}?cron=* * * * * ? 2036").routeId("sched")
.process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
// Do something at cron trigger time
}
}).id("sched.pipline")
.to("log:demo-1?showAll=true&multiline=true&level=INFO");
}
});
reconfigure("sched.pipline", context);
void reconfigure(String downstreamNodeId, CamelContext context) {
for (Route route : context.getRoutes()) { // getRoutes()
returns zero-length list - why????
String id = route.getId(); // null - why???
List<Service> svcs = route.getServices();
Consumer c = route.getConsumer();
}
Route sched = context.getRoute("sched"); // null
Re: How can I dynamically add or modify endpoints in a route?
Posted by Chris Wolf <cw...@gmail.com>.
Actually, after further experimenting, my "reconfgure" worked, but
only after the
CamelContext was started. So the implementation was to just have an initial
route consuming from a direct:, then, when an message comes in, I dynamically
create and add new routes, each headed by a unique instance of
"quartz://", who's
name corresponds to the customer-id, so each customer has their own crontab.
Thanks,
Chris
On Sat, May 18, 2013 at 3:42 AM, Claus Ibsen <cl...@gmail.com> wrote:
> The RouteBuilder is just java code, so I suggest to add getter/setter
> to a MyCronRouteBuilder class which extends RouteBuilder. Then you can
> create a new instance of that, and then use the setter to set your
> options.
>
> And in the configure method you can use the getter to get your
> options, which you can use in the DSL to set the options you want.
>
> On Fri, May 17, 2013 at 6:53 PM, Chris Wolf <cw...@gmail.com> wrote:
>> I need to schedule multiple cron jobs in a route. The number and
>> schedules are not known at compile-time,
>> so I need to programatically configure the route at run-time. An
>> abbreviated version of my non-working
>> attempt is shown below. I created an anonymous RouteBuilder, in which
>> I created a route.
>>
>> After, calling context.addRoutes(...), but before starting the
>> context, I want to programmatically
>> tweak the route definition, as shown by the "reconfigure(...)"
>> function, unfortunately any attempt
>> to lookup the route I just created fails - no routes found. Why? I
>> suspect that the route may actually
>> need to be started for it's initialization to complete, so should I
>> start it, then stop or suspend, then
>> programmatically modify?
>>
>>
>> BTW, I already checked my copy of "Camel In Action" and
>> http://camel.apache.org/faq.html but
>> no answers for me there....
>>
>> context.addRoutes(new RouteBuilder() {
>> public void configure() {
>> from("quartz://demo-1/{{custId}}?cron=* * * * * ? 2036").routeId("sched")
>> .process(new Processor() {
>> @Override
>> public void process(Exchange exchange) throws Exception {
>> // Do something at cron trigger time
>> }
>> }).id("sched.pipline")
>> .to("log:demo-1?showAll=true&multiline=true&level=INFO");
>> }
>> });
>>
>> reconfigure("sched.pipline", context);
>>
>> void reconfigure(String downstreamNodeId, CamelContext context) {
>> for (Route route : context.getRoutes()) { // getRoutes()
>> returns zero-length list - why????
>> String id = route.getId(); // null - why???
>> List<Service> svcs = route.getServices();
>> Consumer c = route.getConsumer();
>> }
>> Route sched = context.getRoute("sched"); // null
>
>
>
> --
> Claus Ibsen
> -----------------
> www.camelone.org: The open source integration conference.
>
> Red Hat, Inc.
> FuseSource is now part of Red Hat
> Email: cibsen@redhat.com
> Web: http://fusesource.com
> Twitter: davsclaus
> Blog: http://davsclaus.com
> Author of Camel in Action: http://www.manning.com/ibsen
Re: How can I dynamically add or modify endpoints in a route?
Posted by Claus Ibsen <cl...@gmail.com>.
The RouteBuilder is just java code, so I suggest to add getter/setter
to a MyCronRouteBuilder class which extends RouteBuilder. Then you can
create a new instance of that, and then use the setter to set your
options.
And in the configure method you can use the getter to get your
options, which you can use in the DSL to set the options you want.
On Fri, May 17, 2013 at 6:53 PM, Chris Wolf <cw...@gmail.com> wrote:
> I need to schedule multiple cron jobs in a route. The number and
> schedules are not known at compile-time,
> so I need to programatically configure the route at run-time. An
> abbreviated version of my non-working
> attempt is shown below. I created an anonymous RouteBuilder, in which
> I created a route.
>
> After, calling context.addRoutes(...), but before starting the
> context, I want to programmatically
> tweak the route definition, as shown by the "reconfigure(...)"
> function, unfortunately any attempt
> to lookup the route I just created fails - no routes found. Why? I
> suspect that the route may actually
> need to be started for it's initialization to complete, so should I
> start it, then stop or suspend, then
> programmatically modify?
>
>
> BTW, I already checked my copy of "Camel In Action" and
> http://camel.apache.org/faq.html but
> no answers for me there....
>
> context.addRoutes(new RouteBuilder() {
> public void configure() {
> from("quartz://demo-1/{{custId}}?cron=* * * * * ? 2036").routeId("sched")
> .process(new Processor() {
> @Override
> public void process(Exchange exchange) throws Exception {
> // Do something at cron trigger time
> }
> }).id("sched.pipline")
> .to("log:demo-1?showAll=true&multiline=true&level=INFO");
> }
> });
>
> reconfigure("sched.pipline", context);
>
> void reconfigure(String downstreamNodeId, CamelContext context) {
> for (Route route : context.getRoutes()) { // getRoutes()
> returns zero-length list - why????
> String id = route.getId(); // null - why???
> List<Service> svcs = route.getServices();
> Consumer c = route.getConsumer();
> }
> Route sched = context.getRoute("sched"); // null
--
Claus Ibsen
-----------------
www.camelone.org: The open source integration conference.
Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cibsen@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
Re: How can I dynamically add or modify endpoints in a route?
Posted by kalyan <re...@gmail.com>.
Did you try it using Dynamic router
<http://camel.apache.org/dynamic-router.html> ?
--
View this message in context: http://camel.465427.n5.nabble.com/How-can-I-dynamically-add-or-modify-endpoints-in-a-route-tp5732775p5732777.html
Sent from the Camel - Users mailing list archive at Nabble.com.