camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "prabumca06@gmail.com" <prabumc...@gmail.com>
Subject Re: Camel routing issue
Date Tue, 23 Jul 2013 11:39:56 GMT
Hi

I need one help,I want set JMSExpiration value before routing messages.

i tried setting JMSExpiration in .setHeader

But it didn't work.I still seeing JMSExpiration is zero.

*Thanks*
Prabu.N


On Wed, Apr 24, 2013 at 9:28 PM, Prabu <prabumca06@gmail.com> wrote:

> Please kindly help me.
>
>
> Regards
> Prabu.N
>
>
> On Wed, Apr 24, 2013 at 2:54 PM, Prabu <prabumca06@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+s465427n5731018h60@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
>



-- 
Thanks & Regards
 Prabu.N




--
View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5736113.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message