Claus, What is the proper way to shutdown the route? I am doing the following from RouteBuilder:
getContext().stopRoute(routeID); But when I do that, I all the routes being shutdown. is this correct ? I see it invoking "org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTasK " and "ShutdownStrategy". Thanks Kal On Sep 30, 2011, at 11:50 AM, Claus Ibsen-2 [via Camel] wrote: > On Fri, Sep 30, 2011 at 1:42 AM, kal2420 <[hidden email]> wrote: > > Thanks Clause, I will give it a try this week end and see how it goes. > > Starting and stoping the route seems a bit expensive, can I use suspend and > > resume? > > > > You can try. But you may have to stop for the selector to be updated. > But give it a go first. > > > > Thanks > > Kal > > > > On Sep 28, 2011, at 2:01 AM, Claus Ibsen-2 [via Camel] wrote: > > > >> Hi > >> > >> Yes you would need to stop the route. Adjust the endpoint. And start > >> the route again to have the JMS selector dynamic updated. > >> > >> CamelContext has API to start/stop rotues by the route id. > >> > >> > >> On Wed, Sep 28, 2011 at 5:10 AM, kal2420 <[hidden email]> wrote: > >> > >> > Thanks Claus, > >> > > >> > This example is very helpful, I am still running into a bit of an > >> > issues. Here is my createRouteBuilder() method ( combined > >> > JmsSelectorTest and JmsSelectorInTest ) : > >> > > >> > @Override > >> > protected RouteBuilder createRouteBuilder() throws Exception { > >> > return new RouteBuilder() { > >> > @Override > >> > public void configure() throws Exception { > >> > JmsEndpoint endpoint = > >> > context.getEndpoint("activemq:test.b", JmsEndpoint.class); > >> > endpoint.setSelector("selector=cheese='y'"); > >> > > >> > from("activemq:test.a").to("activemq:test.b"); > >> > > >> > // > >> > from("activemq:test.b?selector=cheese='y'").to("mock:result"); > >> > from(endpoint).routeId("route-b").to("mock:result"); > >> > > >> > from("activemq:test.c").process(new Processor() { > >> > > >> > @Override > >> > public void process(Exchange arg0) throws Exception { > >> > > >> > > >> > //================================================== > >> > // > >> > // I want to change selector on an endpoint > >> > at run time > >> > // does it require an endpoint restart ? > >> > > >> > //================================================== > >> > > >> > CamelContext ctx = getContext(); > >> > Route rt = ctx.getRoute("route-b"); > >> > JmsEndpoint endpoint = (JmsEndpoint) > >> > rt.getEndpoint(); > >> > endpoint.setSelector("cheese IN ('x', 'n')"); > >> > > >> > } > >> > }).to("activemq:test.b"); > >> > } > >> > }; > >> > } > >> > > >> > > >> > I noticed that if I define the selector as part of the uri every thing > >> > works, but I want to dynamically change the selector at runtime. Let me > >> > know if I am doing something wrong here. > >> > > >> > Thanks > >> > Kal > >> > > >> > On Sep 27, 2011, at 8:09 AM, Claus Ibsen-2 [via Camel] wrote: > >> > > >> >> Hi > >> >> > >> >> I created an unit test which you can take a look at. It uses the IN > >> >> selector > >> >> http://svn.apache.org/viewvc?rev=1176348&view=rev > >> >> > >> >> On Tue, Sep 27, 2011 at 1:58 PM, Claus Ibsen <[hidden email]> wrote: > >> >> > >> >> > On Mon, Sep 26, 2011 at 6:05 PM, kal2420 <[hidden email]> wrote: > >> >> >> Thanks Claus, > >> >> >> > >> >> >> I got busy with work, and I am just getting back to camel. I did > >> >> >> try > >> >> >> looking into event-driven-consusmer, What i really want is to > >> >> >> configure > >> >> >> dynamic selector on activemq queue. Here is how I am trying to > >> >> >> configure > >> >> >> dynamic selector, please tell me if this is correct: > >> >> >> > >> >> >> // once all routes are up and running > >> >> >> // set selector on jms endpoint > >> >> >> CamelContext ctx = getContext(); > >> >> >> JmsEndpoint endpoint = > >> >> >> ctx.getEndpoint("activemq://queue:test-1",JmsEndpoint.class); > >> >> >> // String selector = "userid='test12'"; // also tried with %3D url > >> >> >> format > >> >> >> String selector = "userid IN ('test12' , 'terst234'); > >> >> >> endpoint.setSelector(selector); > >> >> >> > >> >> > > >> >> > So you have a route with that particular endpoint > >> >> > from(endpoint).to("xxx") > >> >> > > >> >> > > >> >> > The selector should use a SQL like syntax. I actually do not know if > >> >> > ActiveMQ has an logging to WARN/ERROR level > >> >> > if the syntax is invalid. > >> >> > > >> >> > > >> >> > > >> >> >> Issue: I am seeing all messages being processed, while i only want > >> >> >> to > >> >> >> process messages where i have userid header value set to 'test12' or > >> >> >> 'terst234' > >> >> >> > >> >> >> Thanks > >> >> >> Kal > >> >> >> > >> >> >> -- > >> >> >> View this message in context: > >> >> >> http://camel.465427.n5.nabble.com/Activemq-dynamic-endpoint-configuration-tp4749853p4841926.html > >> >> >> Sent from the Camel - Users mailing list archive at Nabble.com. > >> >> >> > >> >> > > >> >> > > >> >> > > >> >> > -- > >> >> > Claus Ibsen > >> >> > ----------------- > >> >> > FuseSource > >> >> > Email: [hidden email] > >> >> > Web: http://fusesource.com > >> >> > Twitter: davsclaus, fusenews > >> >> > Blog: http://davsclaus.blogspot.com/ > >> >> > Author of Camel in Action: http://www.manning.com/ibsen/ > >> >> > > >> >> > >> >> > >> >> > >> >> -- > >> >> Claus Ibsen > >> >> ----------------- > >> >> FuseSource > >> >> Email: [hidden email] > >> >> Web: http://fusesource.com > >> >> Twitter: davsclaus, fusenews > >> >> Blog: http://davsclaus.blogspot.com/ > >> >> Author of Camel in Action: http://www.manning.com/ibsen/ > >> >> > >> >> > >> >> If you reply to this email, your message will be added to the > >> >> discussion below: > >> >> http://camel.465427.n5.nabble.com/Activemq-dynamic-endpoint-configuration-tp4749853p4845119.html > >> >> To unsubscribe from Activemq dynamic endpoint configuration, click > >> >> here. > >> > > >> > > >> > > >> > -- > >> > View this message in context: > >> > http://camel.465427.n5.nabble.com/Activemq-dynamic-endpoint-configuration-tp4749853p4847785.html > >> > Sent from the Camel - Users mailing list archive at Nabble.com. > >> > >> > >> > >> -- > >> Claus Ibsen > >> ----------------- > >> FuseSource > >> Email: [hidden email] > >> Web: http://fusesource.com > >> Twitter: davsclaus, fusenews > >> Blog: http://davsclaus.blogspot.com/ > >> Author of Camel in Action: http://www.manning.com/ibsen/ > >> > >> > >> If you reply to this email, your message will be added to the discussion > >> below: > >> http://camel.465427.n5.nabble.com/Activemq-dynamic-endpoint-configuration-tp4749853p4848015.html > >> To unsubscribe from Activemq dynamic endpoint configuration, click here. > > > > > > > > -- > > View this message in context: > > http://camel.465427.n5.nabble.com/Activemq-dynamic-endpoint-configuration-tp4749853p4855106.html > > Sent from the Camel - Users mailing list archive at Nabble.com. > > > > -- > Claus Ibsen > ----------------- > FuseSource > Email: [hidden email] > Web: http://fusesource.com > Twitter: davsclaus, fusenews > Blog: http://davsclaus.blogspot.com/ > Author of Camel in Action: http://www.manning.com/ibsen/ > > > If you reply to this email, your message will be added to the discussion > below: > http://camel.465427.n5.nabble.com/Activemq-dynamic-endpoint-configuration-tp4749853p4857621.html > To unsubscribe from Activemq dynamic endpoint configuration, click here. -- View this message in context: http://camel.465427.n5.nabble.com/Activemq-dynamic-endpoint-configuration-tp4749853p4866938.html Sent from the Camel - Users mailing list archive at Nabble.com.