Please kindly help me.
Regards Prabu.N On Wed, Apr 24, 2013 at 2:54 PM, Prabu <prabumc...@gmail.com> wrote: > Hi All, > > I am facing some issue in my camel code. > > Initially i have used java code to route messages from one end to another > end. > > I modified code to route message using camel routing insight of java code. > > After modified code,i am facing issue in my code. > > 500 Messages stored in DLQ.testQueue > > When i try to re-delivery all 500 messages using active-mq API *moveMessageTo > method.* > > 250 or 200 or 100 messages still i can see in DLQ.testQueue. > > I feel messages re-delivering,But due to some message coming back again > into DLQ. > > Please kindly help me. > > *Regards* > Prabu.N > > > On Wed, Apr 17, 2013 at 5:15 PM, Taariq Levack [via Camel] < > ml-node+s465427n5731018...@n5.nabble.com> wrote: > >> Hi >> >> Looks like java needs a hand[1], after .to(SCHEDULE_QNAME,ONLINE__QNAME), >> you can try endChoice() >> >> [1] >> >> http://camel.apache.org/why-can-i-not-use-when-or-otherwise-in-a-java-camel-route.html >> >> Taariq >> >> >> On Wed, Apr 17, 2013 at 11:00 AM, [hidden >> email]<http://user/SendEmail.jtp?type=node&node=5731018&i=0><[hidden >> email] <http://user/SendEmail.jtp?type=node&node=5731018&i=1> >> > wrote: >> >> > Thanks Claus for your response.. >> > >> > I facing some issue in below code >> > >> > if condition satisfy i want forward into 2 queues,If not it check >> second >> > condition forward into next queue. >> > >> > from(SURVEYINVITATION_QNAME).choice() >> > * .when(SCHEDULE_PREDICATE)* >> > .multicast().to(SCHEDULE_QNAME,ONLINE__QNAME) >> > * .when(ACCOUNT_EVENT_CARE_HANDLER_PREDICATE)* >> > .to(ACCOUNT_EVENT_CARE_HANDLER_QNAME) >> > .otherwise() >> > .to(ERQ_QNAME) >> > .end(); >> > >> > >> > I am getting compilation error,Please correct me what mistake i am >> making >> > here >> > >> > *Regards* >> > Prabu.N >> > >> > >> > >> > >> > >> > >> > On Wed, Apr 17, 2013 at 2:21 PM, Claus Ibsen-2 [via Camel] < >> > [hidden email] <http://user/SendEmail.jtp?type=node&node=5731018&i=2>> >> wrote: >> > >> > > Hi >> > > >> > > If no destinations is returned, then the message is not routed >> anywhere. >> > > >> > > On Tue, Apr 16, 2013 at 3:44 PM, [hidden email]< >> > http://user/SendEmail.jtp?type=node&node=5731013&i=0> >> > > <[hidden email] <http://user/SendEmail.jtp?type=node&node=5731013&i=1>> >> >> > > wrote: >> > > >> > > > *One quick question.* >> > > > >> > > > >> > > >> > >> from("activemq:queue:HHH.InboundQueue").multicast().beanRef("recipientsGenerator") >> >> > > >> > > > >> > > > @RecipientList() >> > > > public Set<String> routeTo(Exchange ex) { >> > > > >> > > > final Set<String> destinations = new HashSet<String>(); >> > > > >> > > > //based on condition we add messages header/content ,We add queue >> > names >> > > in >> > > > destinations varible. >> > > > //destinations.add("activemq:queue:listqueue") >> > > > >> > > > return destinations; >> > > > } >> > > > >> > > > some cases,messages content not satisfy any condition and it >> returning >> > > > empty destinations set. >> > > > >> > > > If destinations set is empty where message will go?. >> > > > >> > > > Because,i can't see messages in HHH.InboundQueue and any queues. >> > > > >> > > > *Regards* >> > > > Prabu.N >> > > > >> > > > >> > > > >> > > > >> > > > On Mon, Apr 15, 2013 at 10:00 PM, Prabu <[hidden email]< >> > http://user/SendEmail.jtp?type=node&node=5731013&i=2>> >> > > wrote: >> > > > >> > > >> So for dynamic queue i have to use only recipientlist correct,we >> can't >> > > use >> > > >> .to >> > > >> >> > > >> One more question,i can't use otherwise in choice please correct >> if my >> > > >> syntax is wrong. >> > > >> >> > > >> >> > > >> from(INBOUND_QUEUE) >> > > >> .choice().when(header(TYPE).isNotNull()) >> > > >> .recipientList(simple("activemq:queue:Inbound.${header.TYPE}")) >> > > >> .otherwise() >> > > >> .to(ERQ_QNAME) >> > > >> .endChoice(); >> > > >> >> > > >> After execute i am getting following error. >> > > >> >> > > >> Error: >> > > >> >> > > >> Router.java:22: cannot find symbol >> > > >> symbol : method otherwise() >> > > >> location: class >> > > >> org.apache.camel.model.RecipientListDefinition<org.apache.camel. >> > > >> model.ChoiceDefinition> >> > > >> .otherwise() >> > > >> ^ >> > > >> >> > > >> >> > > >> >> > > >> On Mon, Apr 15, 2013 at 8:55 PM, Claus Ibsen-2 [via Camel] < >> > > >> [hidden email] < >> http://user/SendEmail.jtp?type=node&node=5731013&i=3 >> >> > >> >> > > wrote: >> > > >> >> > > >>> Hi >> > > >>> >> > > >>> Yes recipient list uses an expression for evaluating where to >> send >> > the >> > > >>> message to. >> > > >>> See its doc >> > > >>> http://camel.apache.org/recipient-list.html >> > > >>> >> > > >>> And this FAQ >> > > >>> http://camel.apache.org/how-do-i-use-dynamic-uri-in-to.html >> > > >>> >> > > >>> And there is no performance overhead. eg when you send the >> message to >> > > >>> a previous destination, then that endpoints/producer is reused. >> > > >>> >> > > >>> >> > > >>> On Mon, Apr 15, 2013 at 2:05 PM, [hidden email]< >> > > http://user/SendEmail.jtp?type=node&node=5730920&i=0> >> > > >>> <[hidden email] < >> > http://user/SendEmail.jtp?type=node&node=5730920&i=1>> >> > > >> > > >>> wrote: >> > > >>> >> > > >>> > Question:1 >> > > >>> > >> > > >>> > I am having code like blow.based on condition i want forward >> into >> > > >>> dynamic >> > > >>> > queue. >> > > >>> > >> > > >>> > .when(header(TYPE).isNotNull()) >> > > >>> > >> .recipientList(simple("activemq:queue:Inbound.${header.TYPE}")) >> > > >>> > >> > > >>> > i want to use .to(simple ) insight of .recipientList(simple) >> > > >>> > >> > > >>> > Please suggest is it possible?.why it is not possible is there >> any >> > > >>> > performance issue if i use .recipientList(simple) >> > > >>> > >> > > >>> > Questuon:2 >> > > >>> > >> > > >>> > Error in code >> > > >>> > >> > > >>> > from(INBOUND_QUEUE) >> > > >>> > .choice().when(header(TYPE).isNotNull()) >> > > >>> > >> .recipientList(simple("activemq:queue:Inbound.${header.TYPE}")) >> > > >>> > .otherwise() >> > > >>> > .to(ERQ_QNAME) >> > > >>> > .endChoice(); >> > > >>> > >> > > >>> > After execute i am getting following error. >> > > >>> > >> > > >>> > Error: >> > > >>> > >> > > >>> > Router.java:22: cannot find symbol >> > > >>> > symbol : method otherwise() >> > > >>> > location: class >> > > >>> > >> org.apache.camel.model.RecipientListDefinition<org.apache.camel. >> > > >>> > model.ChoiceDefinition> >> > > >>> > .otherwise() >> > > >>> > ^ >> > > >>> > >> > > >>> > Question:3 >> > > >>> > >> > > >>> > I having more than 85 queues.Based on condition i want to >> forward >> > to >> > > >>> correct >> > > >>> > queue. >> > > >>> > >> > > >>> > In my route builder i having code below for all 85 queus. >> > > >>> > >> > > >>> > from(ALERT_QNAME).choice() >> > > >>> > .when(ALERT_PREDICATE).to(ALERT_QNAME) >> > > >>> > .otherwise() >> > > >>> > .to(ERQ_QNAME) >> > > >>> > .end(); >> > > >>> > >> > > >>> > I feel like because of my code performance getting >> degrade.Please >> > > >>> suggest if >> > > >>> > i am wrong? >> > > >>> > >> > > >>> > When i open jconsole i am getting white screen and queues some >> time >> > > not >> > > >>> > showing any attribute? >> > > >>> > >> > > >>> > Please kindly help me. >> > > >>> > >> > > >>> > >> > > >>> > >> > > >>> > -- >> > > >>> > View this message in context: >> > > >>> >> > > >> > >> http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5730898.html >> > > >>> >> > > >>> > Sent from the Camel - Users mailing list archive at Nabble.com. >> > > >>> >> > > >>> >> > > >>> >> > > >>> -- >> > > >>> Claus Ibsen >> > > >>> ----------------- >> > > >>> Red Hat, Inc. >> > > >>> FuseSource is now part of Red Hat >> > > >>> Email: [hidden email]< >> > > http://user/SendEmail.jtp?type=node&node=5730920&i=2> >> > > >>> Web: http://fusesource.com >> > > >>> Twitter: davsclaus >> > > >>> Blog: http://davsclaus.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: >> > > >>> >> > > >>> >> > > >> > > >>> . >> > > >>> NAML< >> > > >> > >> http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml >> > > >> > > >> > > >>> >> > > >> >> > > >> >> > > >> >> > > >> -- >> > > >> Thanks & Regards >> > > >> Prabu.N >> > > >> >> > > > >> > > > >> > > > >> > > > -- >> > > > Thanks & Regards >> > > > Prabu.N >> > > > >> > > > >> > > > >> > > > >> > > > -- >> > > > View this message in context: >> > > >> > >> http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5730973.html >> > > >> > > > Sent from the Camel - Users mailing list archive at Nabble.com. >> > > >> > > >> > > >> > > -- >> > > Claus Ibsen >> > > ----------------- >> > > Red Hat, Inc. >> > > FuseSource is now part of Red Hat >> > > Email: [hidden email]< >> > http://user/SendEmail.jtp?type=node&node=5731013&i=4> >> > > Web: http://fusesource.com >> > > Twitter: davsclaus >> > > Blog: http://davsclaus.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/Camel-routing-issue-tp5730094p5731013.html >> > > To unsubscribe from Camel routing issue, click here< >> > >> > >> > > . >> > > NAML< >> > >> http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml >> > > >> > > >> > >> > >> > >> > -- >> > Thanks & Regards >> > Prabu.N >> > >> > >> > >> > >> > -- >> > View this message in context: >> > >> http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5731014.html >> >> > Sent from the Camel - Users mailing list archive at Nabble.com. >> > >> >> >> ------------------------------ >> If you reply to this email, your message will be added to the >> discussion below: >> >> http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5731018.html >> To unsubscribe from Camel routing issue, click >> here<http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=5730094&code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg=> >> . >> NAML<http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml> >> > > > > -- > Thanks & Regards > Prabu.N > -- Thanks & Regards Prabu.N -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5731461.html Sent from the Camel - Users mailing list archive at Nabble.com.
