Camel routing issue
I have created some routes. Following is the code which is having issues. Following is the expected behavior: Exchange at first gets processed at hourlyFeedParts queue and then passed to dailyProcessor. In dailyProcessor a property currHour is being checked if it is 23 or not. If not, it just passes on. If currHour == 23, code inside it shall be processed. This part again has following functionality, If property feedsleft is not zero, all code inside the choice currHour==23 is executed. This is fine. if property feedsLeft is zero, code inside it processed. Code within looks for any further messages. If yes, they are send to hourlyFeedParts. Here comes the issue: If there is any message to be processed the code beyond to(direct:hourlyFeedParts) is not executed. Though, if nothing is returned, the code works fine. I guess the issue could be code ends at to. So, what shall be the alternative? from(direct:dailyProcessor) .choice() .when(simple(${property.currHour} == 23)) .choice() .when(simple(${property.feedsLeft} == 0)) .split(beanExpression(APNProcessor.class, recheckFeeds)) .to(direct:hourlyFeedParts) .endChoice() .end() .split(beanExpression(new S3FileKeyProcessorFactory(), setAPNS3Header)) .parallelProcessing() .id(APN Daily PreProcessor / S3 key generator ) .log(Uploading file ${file:name}) .to({{apn.destination}}) .id(APN Daily S3 uploader) .log(Uploaded file ${file:name} to S3) .endChoice() .end() -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5742807.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue
I think you need to end the inner split with a .end() call. When you split the route you replace the current body with one of the split bodies and they get executed individually. If you want to do something after that split is processed, you have to end the split and then restore the exchange body that you are processing. Put a tracer on the route and study the tracer output carefully. *Robert Simmons Jr. MSc. - Lead Java Architect @ EA* *Author of: Hardcore Java (2003) and Maintainable Java (2012)* *LinkedIn: **http://www.linkedin.com/pub/robert-simmons/40/852/a39 http://www.linkedin.com/pub/robert-simmons/40/852/a39* On Fri, Nov 8, 2013 at 2:56 AM, sumitshining sumitshin...@gmail.com wrote: I have created some routes. Following is the code which is having issues. Following is the expected behavior: Exchange at first gets processed at hourlyFeedParts queue and then passed to dailyProcessor. In dailyProcessor a property currHour is being checked if it is 23 or not. If not, it just passes on. If currHour == 23, code inside it shall be processed. This part again has following functionality, If property feedsleft is not zero, all code inside the choice currHour==23 is executed. This is fine. if property feedsLeft is zero, code inside it processed. Code within looks for any further messages. If yes, they are send to hourlyFeedParts. Here comes the issue: If there is any message to be processed the code beyond to(direct:hourlyFeedParts) is not executed. Though, if nothing is returned, the code works fine. I guess the issue could be code ends at to. So, what shall be the alternative? from(direct:dailyProcessor) .choice() .when(simple(${property.currHour} == 23)) .choice() .when(simple(${property.feedsLeft} == 0)) .split(beanExpression(APNProcessor.class, recheckFeeds)) .to(direct:hourlyFeedParts) .endChoice() .end() .split(beanExpression(new S3FileKeyProcessorFactory(), setAPNS3Header)) .parallelProcessing() .id(APN Daily PreProcessor / S3 key generator ) .log(Uploading file ${file:name}) .to({{apn.destination}}) .id(APN Daily S3 uploader) .log(Uploaded file ${file:name} to S3) .endChoice() .end() -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5742807.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue
[via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5736234i=2 wrote: It's not really so difficult to find an example, if you spend only a few minutes: https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java;h=52b430b17a7ffc0ca977864ea8c6238050f90a57;hb=HEAD Best, Christian - Software Integration Specialist Apache Camel committer: https://camel.apache.org/team V.P. Apache Camel: https://www.apache.org/foundation/ Apache Member: https://www.apache.org/foundation/members.html https://www.linkedin.com/pub/christian-mueller/11/551/642 -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5736163.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5736224.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-tp5730094p5736234.html To unsubscribe from Camel routing issue, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5741054.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue
(*MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME*).process(new Processor() { public void process(Exchange exchange) throws Exception { } .setHeader(MEMOS_TARGET_SERVER,header(MASTER_HANDLER)) .setHeader(JMSExpiration,constant(EXPIRY_TIME)) .to(CONSUMER_TEST_QNAME) .setHeader(MEMOS_TARGET_SERVER, header(SLAVE_HANDLER)) .setHeader(JMSExpiration,constant(EXPIRY_TIME)) .to(CONSUMER_TEST_QNAME) .end(); But,messages not expiring Please kindly help me *Thanks* Prabu.N On Wed, Jul 24, 2013 at 1:46 AM, Christian Mueller [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5736234i=2 wrote: It's not really so difficult to find an example, if you spend only a few minutes: https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java;h=52b430b17a7ffc0ca977864ea8c6238050f90a57;hb=HEAD Best, Christian - Software Integration Specialist Apache Camel committer: https://camel.apache.org/team V.P. Apache Camel: https://www.apache.org/foundation/ Apache Member: https://www.apache.org/foundation/members.html https://www.linkedin.com/pub/christian-mueller/11/551/642 -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5736163.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5736224.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-tp5730094p5736234.html To unsubscribe from Camel routing issue, click here http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5741054.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue after upgrade into active-mq 5.8
in MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME not calling memosprocess class. Please kindly help me. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738702.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738708.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738709.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738712.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738713.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5738700code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczODcwMHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-after-upgrade-into-active-mq-5-8-tp5738700p5738804.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue after upgrade into active-mq 5.8
headers = msg.getHeaders(); String eventType= (String) headers.get(EVENT_TYPE); String msgId= (String) headers.get(MESSAGE_ID); System.out.println(Memos-msgid:+msgId); int msg_Expiry_Time = Integer.parseInt((String) headers.get(EXPIRY_TIME)); InetAddress address = InetAddress.getLocalHost(); String hostname = address.getHostName(); long MSG_EXPIRY = System.currentTimeMillis() + msg_Expiry_Time; headers.put(JMSExpiration,MSG_EXPIRY); String restfulServiceURL =(String) headers.get(MEMOS_RESTFULSERVICE_URL); restfulServiceURL=restfulServiceURL+update; if (eventType.equalsIgnoreCase(CONSUMER_EVENT_TYPE)) { String serversList= (String) headers.get(MEMOS_TARGET_SERVERS); String servers [] = serversList.split(:); String handler1 = ; String handler2 = ; if (servers.length =2) { handler1 = servers[0]; handler2 = servers[1]; } headers.put(MEMOS_TARGET_SERVER,handler1); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); headers.put(MEMOS_TARGET_SERVER,handler2); new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); }else if(eventType.equalsIgnoreCase(PRODUCER_EVENT_TYPE)){ new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(PRODUCER_TEST_QNAME,Producer test,headers); } } above code worked fine in active 5.5 but after upgrade into active 5.8 it is not working Message getting hang in MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME not calling memosprocess class. Please kindly help me. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738702.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738708.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738709.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738712.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738713.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp
Re: Camel routing issue after upgrade into active-mq 5.8
sort of ack mode are you using on the connection? On Wed, Sep 4, 2013 at 11:50 AM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5738702i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5738702i=1 wrote: My code worked fine in activemq 5.5 only issue after upgrading activemq 5.8 Camel i having code like from(MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME).process(new MemosProcess(getContext().createProducerTemplate())) .end(); class MemosProcess implements Processor,QnamesInterface { private static final Logger LOG = LoggerFactory.getLogger(MemosProcess.class); ProducerTemplate prodtemplate=null; public MemosProcess(){ } public MemosProcess(ProducerTemplate template) { this.prodtemplate=template; } @Override public void process(Exchange exchange) throws Exception { JmsMessage msg = (JmsMessage) exchange.getIn(); MapString, Object headers = msg.getHeaders(); String eventType= (String) headers.get(EVENT_TYPE); String msgId= (String) headers.get(MESSAGE_ID); System.out.println(Memos-msgid:+msgId); int msg_Expiry_Time = Integer.parseInt((String) headers.get(EXPIRY_TIME)); InetAddress address = InetAddress.getLocalHost(); String hostname = address.getHostName(); long MSG_EXPIRY = System.currentTimeMillis() + msg_Expiry_Time; headers.put(JMSExpiration,MSG_EXPIRY); String restfulServiceURL =(String) headers.get(MEMOS_RESTFULSERVICE_URL); restfulServiceURL=restfulServiceURL+update; if (eventType.equalsIgnoreCase(CONSUMER_EVENT_TYPE)) { String serversList= (String) headers.get(MEMOS_TARGET_SERVERS); String servers [] = serversList.split(:); String handler1 = ; String handler2 = ; if (servers.length =2) { handler1 = servers[0]; handler2 = servers[1]; } headers.put(MEMOS_TARGET_SERVER,handler1); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); headers.put(MEMOS_TARGET_SERVER,handler2); new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); }else if(eventType.equalsIgnoreCase(PRODUCER_EVENT_TYPE)){ new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(PRODUCER_TEST_QNAME,Producer test,headers); } } above code worked fine in active 5.5 but after upgrade into active 5.8 it is not working Message getting hang in MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME not calling memosprocess class. Please kindly help me. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738702.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738708.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738709.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble
Re: Camel routing issue after upgrade into active-mq 5.8
(:); String handler1 = ; String handler2 = ; if (servers.length =2) { handler1 = servers[0]; handler2 = servers[1]; } headers.put(MEMOS_TARGET_SERVER,handler1); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); headers.put(MEMOS_TARGET_SERVER,handler2); new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); }else if(eventType.equalsIgnoreCase(PRODUCER_EVENT_TYPE)){ new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(PRODUCER_TEST_QNAME,Producer test,headers); } } above code worked fine in active 5.5 but after upgrade into active 5.8 it is not working Message getting hang in MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME not calling memosprocess class. Please kindly help me. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738702.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738708.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738709.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738712.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738713.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5738700code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczODcwMHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-after-upgrade-into-active-mq-5-8-tp5738700p5738719.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue after upgrade into active-mq 5.8
. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738702.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738708.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738709.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738712.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738713.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5738700code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczODcwMHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-after-upgrade-into-active-mq-5-8-tp5738700p5738763.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue after upgrade into active-mq 5.8
getting hang in MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME not calling memosprocess class. Please kindly help me. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738702.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738708.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738709.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738712.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738713.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5738700code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczODcwMHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-after-upgrade-into-active-mq-5-8-tp5738700p5738796.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue after upgrade into active-mq 5.8
in active 5.5 but after upgrade into active 5.8 it is not working Message getting hang in MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME not calling memosprocess class. Please kindly help me. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738702.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738708.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738709.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738712.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738713.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5738700code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczODcwMHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-after-upgrade-into-active-mq-5-8-tp5738700p5738804.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue
Hi All, Camel i having code like this from(MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME).process(new MemosProcess(* getContext().**createProducerTemplate()*)) .end(); Above code worked fine in activemq 5.5 but after upgrade into active 5.8 it is not working. Message getting hang in MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME not calling memosprocess class. Please kindly help me. *Thanks* Prabu.N On Wed, Jul 24, 2013 at 11:49 PM, Christian Mueller [via Camel] ml-node+s465427n5736234...@n5.nabble.com wrote: The test ensure it works: @Test public void testInOnlyJMSExpiration() throws Exception { MockEndpoint mock = getMockEndpoint(mock:result); mock.expectedMessageCount(1); long ttl = System.currentTimeMillis() + 5000; template.sendBodyAndHeader(activemq:queue:bar?preserveMessageQos=true, Hello World, JMSExpiration, ttl); // sleep just a little Thread.sleep(2000); // use timeout in case running on slow box Exchange bar = consumer.receive(activemq:queue:bar, 1); assertNotNull(Should be a message on queue, bar); template.send(activemq:queue:foo, bar); assertMockEndpointsSatisfied(); } @Test public void testInOnlyJMSExpirationNoMessage() throws Exception { MockEndpoint mock = getMockEndpoint(mock:result); mock.expectedMessageCount(1); long ttl = System.currentTimeMillis() + 2000; template.sendBodyAndHeader(activemq:queue:bar?preserveMessageQos=true, Hello World, JMSExpiration, ttl); // sleep more so the message is expired Thread.sleep(5000); Exchange bar = consumer.receiveNoWait(activemq:queue:bar); assertNull(Should NOT be a message on queue, bar); template.sendBody(activemq:queue:foo, Hello World); assertMockEndpointsSatisfied(); } protected RouteBuilder createRouteBuilder() throws Exception { return new RouteBuilder() { public void configure() throws Exception { from(activemq:queue:foo) .to(mock:result); } }; } Check what you do differently... Best, Christian - Software Integration Specialist Apache Camel committer: https://camel.apache.org/team V.P. Apache Camel: https://www.apache.org/foundation/ Apache Member: https://www.apache.org/foundation/members.html https://www.linkedin.com/pub/christian-mueller/11/551/642 On Wed, Jul 24, 2013 at 4:42 PM, [hidden email]http://user/SendEmail.jtp?type=nodenode=5736234i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5736234i=1wrote: Hi Chris, Thanks so much for the information. I have tried different property but it did not work. Please find my code below. *public static final String CONSUMER_TEST_QNAME = activemq:queue:ConsumerTestHandler?jmsMessageType=TextpreserveMessageQos=true; * * * *public static final String PRODUCER_TEST_QNAME = activemq:queue:ProducerTestHandler?jmsMessageType=TextpreserveMessageQos=true; * ** *public static final String MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME = activemq:queue:Inbound.Memos.Consumer.Test;* * * *public static final String MESSAGING_TEST_PRODUCER_TYPE_SPECIFIC_QNAME = activemq:queue:Inbound.Memos.Producer.Test;* from(*MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME*).process(new Processor() { public void process(Exchange exchange) throws Exception { } .setHeader(MEMOS_TARGET_SERVER,header(MASTER_HANDLER)) .setHeader(JMSExpiration,constant(EXPIRY_TIME)) .to(CONSUMER_TEST_QNAME) .setHeader(MEMOS_TARGET_SERVER, header(SLAVE_HANDLER)) .setHeader(JMSExpiration,constant(EXPIRY_TIME)) .to(CONSUMER_TEST_QNAME) .end(); But,messages not expiring Please kindly help me *Thanks* Prabu.N On Wed, Jul 24, 2013 at 1:46 AM, Christian Mueller [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5736234i=2 wrote: It's not really so difficult to find an example, if you spend only a few minutes: https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java;h=52b430b17a7ffc0ca977864ea8c6238050f90a57;hb=HEAD Best, Christian - Software Integration Specialist Apache Camel committer: https://camel.apache.org/team V.P. Apache Camel: https://www.apache.org/foundation/ Apache Member: https://www.apache.org/foundation/members.html https://www.linkedin.com/pub/christian-mueller/11/551/642 -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5736163.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro
Camel routing issue after upgrade into active-mq 5.8
My code worked fine in activemq 5.5 only issue after upgrading activemq 5.8 Camel i having code like from(MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME).process(new MemosProcess(getContext().createProducerTemplate())) .end(); class MemosProcess implements Processor,QnamesInterface { private static final Logger LOG = LoggerFactory.getLogger(MemosProcess.class); ProducerTemplate prodtemplate=null; public MemosProcess(){ } public MemosProcess(ProducerTemplate template) { this.prodtemplate=template; } @Override public void process(Exchange exchange) throws Exception { JmsMessage msg = (JmsMessage) exchange.getIn(); MapString, Object headers = msg.getHeaders(); String eventType= (String) headers.get(EVENT_TYPE); String msgId= (String) headers.get(MESSAGE_ID); System.out.println(Memos-msgid:+msgId); int msg_Expiry_Time = Integer.parseInt((String) headers.get(EXPIRY_TIME)); InetAddress address = InetAddress.getLocalHost(); String hostname = address.getHostName(); long MSG_EXPIRY = System.currentTimeMillis() + msg_Expiry_Time; headers.put(JMSExpiration,MSG_EXPIRY); String restfulServiceURL =(String) headers.get(MEMOS_RESTFULSERVICE_URL); restfulServiceURL=restfulServiceURL+update; if (eventType.equalsIgnoreCase(CONSUMER_EVENT_TYPE)) { String serversList= (String) headers.get(MEMOS_TARGET_SERVERS); String servers [] = serversList.split(:); String handler1 = ; String handler2 = ; if (servers.length =2) { handler1 = servers[0]; handler2 = servers[1]; } headers.put(MEMOS_TARGET_SERVER,handler1); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); headers.put(MEMOS_TARGET_SERVER,handler2); new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); }else if(eventType.equalsIgnoreCase(PRODUCER_EVENT_TYPE)){ new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(PRODUCER_TEST_QNAME,Producer test,headers); } } above code worked fine in active 5.5 but after upgrade into active 5.8 it is not working Message getting hang in MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME not calling memosprocess class. Please kindly help me. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue after upgrade into active-mq 5.8
What does it do? Does the broker dispatch messages to the client (you can see with the in-flight metrics on the broker)? Can you turn up the logging and see what camel is doing? what sort of ack mode are you using on the connection? On Wed, Sep 4, 2013 at 11:50 AM, prabumc...@gmail.com prabumc...@gmail.comwrote: My code worked fine in activemq 5.5 only issue after upgrading activemq 5.8 Camel i having code like from(MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME).process(new MemosProcess(getContext().createProducerTemplate())) .end(); class MemosProcess implements Processor,QnamesInterface { private static final Logger LOG = LoggerFactory.getLogger(MemosProcess.class); ProducerTemplate prodtemplate=null; public MemosProcess(){ } public MemosProcess(ProducerTemplate template) { this.prodtemplate=template; } @Override public void process(Exchange exchange) throws Exception { JmsMessage msg = (JmsMessage) exchange.getIn(); MapString, Object headers = msg.getHeaders(); String eventType= (String) headers.get(EVENT_TYPE); String msgId= (String) headers.get(MESSAGE_ID); System.out.println(Memos-msgid:+msgId); int msg_Expiry_Time = Integer.parseInt((String) headers.get(EXPIRY_TIME)); InetAddress address = InetAddress.getLocalHost(); String hostname = address.getHostName(); long MSG_EXPIRY = System.currentTimeMillis() + msg_Expiry_Time; headers.put(JMSExpiration,MSG_EXPIRY); String restfulServiceURL =(String) headers.get(MEMOS_RESTFULSERVICE_URL); restfulServiceURL=restfulServiceURL+update; if (eventType.equalsIgnoreCase(CONSUMER_EVENT_TYPE)) { String serversList= (String) headers.get(MEMOS_TARGET_SERVERS); String servers [] = serversList.split(:); String handler1 = ; String handler2 = ; if (servers.length =2) { handler1 = servers[0]; handler2 = servers[1]; } headers.put(MEMOS_TARGET_SERVER,handler1); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); headers.put(MEMOS_TARGET_SERVER,handler2); new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); }else if(eventType.equalsIgnoreCase(PRODUCER_EVENT_TYPE)){ new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(PRODUCER_TEST_QNAME,Producer test,headers); } } above code worked fine in active 5.5 but after upgrade into active 5.8 it is not working Message getting hang in MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME not calling memosprocess class. Please kindly help me. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta
Re: Camel routing issue after upgrade into active-mq 5.8
I am using simple failover url Failover:(ssl://br1,ssl://br2) my aim is set expiry time to message thats why I am producertemplate it creating issue here. Message will send Type specific queue After that camel use producertemplate set expiry time to msg it send msg to another outbound queue. Now what is happening message staying on type specific queue and it routing message each 3 to 5 min time.taking long time to route msg. Pls kindly help me. On Sep 5, 2013 1:42 AM, ceposta [via Camel] ml-node+s465427n5738702...@n5.nabble.com wrote: What does it do? Does the broker dispatch messages to the client (you can see with the in-flight metrics on the broker)? Can you turn up the logging and see what camel is doing? what sort of ack mode are you using on the connection? On Wed, Sep 4, 2013 at 11:50 AM, [hidden email]http://user/SendEmail.jtp?type=nodenode=5738702i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5738702i=1wrote: My code worked fine in activemq 5.5 only issue after upgrading activemq 5.8 Camel i having code like from(MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME).process(new MemosProcess(getContext().createProducerTemplate())) .end(); class MemosProcess implements Processor,QnamesInterface { private static final Logger LOG = LoggerFactory.getLogger(MemosProcess.class); ProducerTemplate prodtemplate=null; public MemosProcess(){ } public MemosProcess(ProducerTemplate template) { this.prodtemplate=template; } @Override public void process(Exchange exchange) throws Exception { JmsMessage msg = (JmsMessage) exchange.getIn(); MapString, Object headers = msg.getHeaders(); String eventType= (String) headers.get(EVENT_TYPE); String msgId= (String) headers.get(MESSAGE_ID); System.out.println(Memos-msgid:+msgId); int msg_Expiry_Time = Integer.parseInt((String) headers.get(EXPIRY_TIME)); InetAddress address = InetAddress.getLocalHost(); String hostname = address.getHostName(); long MSG_EXPIRY = System.currentTimeMillis() + msg_Expiry_Time; headers.put(JMSExpiration,MSG_EXPIRY); String restfulServiceURL =(String) headers.get(MEMOS_RESTFULSERVICE_URL); restfulServiceURL=restfulServiceURL+update; if (eventType.equalsIgnoreCase(CONSUMER_EVENT_TYPE)) { String serversList= (String) headers.get(MEMOS_TARGET_SERVERS); String servers [] = serversList.split(:); String handler1 = ; String handler2 = ; if (servers.length =2) { handler1 = servers[0]; handler2 = servers[1]; } headers.put(MEMOS_TARGET_SERVER,handler1); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); headers.put(MEMOS_TARGET_SERVER,handler2); new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); }else if(eventType.equalsIgnoreCase(PRODUCER_EVENT_TYPE)){ new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(PRODUCER_TEST_QNAME,Producer test,headers); } } above code worked fine in active 5.5 but after upgrade into active 5.8 it is not working Message getting hang in MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME not calling memosprocess class. Please kindly help me. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta http://www.christianposta.com/blog -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738702.html To unsubscribe from Camel routing issue after upgrade into active-mq 5.8, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5738700code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczODcwMHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http
Re: Camel routing issue after upgrade into active-mq 5.8
Yes I can some messages in dlq.type.specfic.queue and some messgaes on type specific queue. Messges not route to outbound queue. Pls suggest what is the fix for this. It almost 2 days I am having this issue pls suggest On Sep 5, 2013 8:17 AM, ceposta [via Camel] ml-node+s465427n5738709...@n5.nabble.com wrote: Maybe your TTL is set too short and the broker is rejecting those messages. Can you check your DLQ to see whether the messages are in there? On Wed, Sep 4, 2013 at 7:07 PM, [hidden email]http://user/SendEmail.jtp?type=nodenode=5738709i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5738709i=1wrote: I am using simple failover url Failover:(ssl://br1,ssl://br2) my aim is set expiry time to message thats why I am producertemplate it creating issue here. Message will send Type specific queue After that camel use producertemplate set expiry time to msg it send msg to another outbound queue. Now what is happening message staying on type specific queue and it routing message each 3 to 5 min time.taking long time to route msg. Pls kindly help me. On Sep 5, 2013 1:42 AM, ceposta [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5738709i=2 wrote: What does it do? Does the broker dispatch messages to the client (you can see with the in-flight metrics on the broker)? Can you turn up the logging and see what camel is doing? what sort of ack mode are you using on the connection? On Wed, Sep 4, 2013 at 11:50 AM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5738702i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5738702i=1 wrote: My code worked fine in activemq 5.5 only issue after upgrading activemq 5.8 Camel i having code like from(MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME).process(new MemosProcess(getContext().createProducerTemplate())) .end(); class MemosProcess implements Processor,QnamesInterface { private static final Logger LOG = LoggerFactory.getLogger(MemosProcess.class); ProducerTemplate prodtemplate=null; public MemosProcess(){ } public MemosProcess(ProducerTemplate template) { this.prodtemplate=template; } @Override public void process(Exchange exchange) throws Exception { JmsMessage msg = (JmsMessage) exchange.getIn(); MapString, Object headers = msg.getHeaders(); String eventType= (String) headers.get(EVENT_TYPE); String msgId= (String) headers.get(MESSAGE_ID); System.out.println(Memos-msgid:+msgId); int msg_Expiry_Time = Integer.parseInt((String) headers.get(EXPIRY_TIME)); InetAddress address = InetAddress.getLocalHost(); String hostname = address.getHostName(); long MSG_EXPIRY = System.currentTimeMillis() + msg_Expiry_Time; headers.put(JMSExpiration,MSG_EXPIRY); String restfulServiceURL =(String) headers.get(MEMOS_RESTFULSERVICE_URL); restfulServiceURL=restfulServiceURL+update; if (eventType.equalsIgnoreCase(CONSUMER_EVENT_TYPE)) { String serversList= (String) headers.get(MEMOS_TARGET_SERVERS); String servers [] = serversList.split(:); String handler1 = ; String handler2 = ; if (servers.length =2) { handler1 = servers[0]; handler2 = servers[1]; } headers.put(MEMOS_TARGET_SERVER,handler1); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); headers.put(MEMOS_TARGET_SERVER,handler2); new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,Consumer test,headers); }else if(eventType.equalsIgnoreCase(PRODUCER_EVENT_TYPE)){ new MemosProcess().callService(msgId, hostname,restfulServiceURL); prodtemplate.sendBodyAndHeaders(PRODUCER_TEST_QNAME,Producer test,headers); } } above code worked fine in active 5.5 but after upgrade into active 5.8 it is not working Message getting hang in MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME not calling memosprocess class. Please kindly help me. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700.html Sent from the Camel - Users mailing list archive at Nabble.com. -- *Christian Posta* http://www.christianposta.com/blog twitter
Re: Camel routing issue
Hi Chris, Thanks so much for the information. I have tried different property but it did not work. Please find my code below. *public static final String CONSUMER_TEST_QNAME = activemq:queue:ConsumerTestHandler?jmsMessageType=TextpreserveMessageQos=true; * * * *public static final String PRODUCER_TEST_QNAME = activemq:queue:ProducerTestHandler?jmsMessageType=TextpreserveMessageQos=true; * ** *public static final String MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME = activemq:queue:Inbound.Memos.Consumer.Test;* * * *public static final String MESSAGING_TEST_PRODUCER_TYPE_SPECIFIC_QNAME = activemq:queue:Inbound.Memos.Producer.Test;* from(*MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME*).process(new Processor() { public void process(Exchange exchange) throws Exception { } .setHeader(MEMOS_TARGET_SERVER,header(MASTER_HANDLER)) .setHeader(JMSExpiration,constant(EXPIRY_TIME)) .to(CONSUMER_TEST_QNAME) .setHeader(MEMOS_TARGET_SERVER, header(SLAVE_HANDLER)) .setHeader(JMSExpiration,constant(EXPIRY_TIME)) .to(CONSUMER_TEST_QNAME) .end(); But,messages not expiring Please kindly help me *Thanks* Prabu.N On Wed, Jul 24, 2013 at 1:46 AM, Christian Mueller [via Camel] ml-node+s465427n5736163...@n5.nabble.com wrote: It's not really so difficult to find an example, if you spend only a few minutes: https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java;h=52b430b17a7ffc0ca977864ea8c6238050f90a57;hb=HEAD Best, Christian - Software Integration Specialist Apache Camel committer: https://camel.apache.org/team V.P. Apache Camel: https://www.apache.org/foundation/ Apache Member: https://www.apache.org/foundation/members.html https://www.linkedin.com/pub/christian-mueller/11/551/642 -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5736163.html To unsubscribe from Camel routing issue, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5736224.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue
The test ensure it works: @Test public void testInOnlyJMSExpiration() throws Exception { MockEndpoint mock = getMockEndpoint(mock:result); mock.expectedMessageCount(1); long ttl = System.currentTimeMillis() + 5000; template.sendBodyAndHeader(activemq:queue:bar?preserveMessageQos=true, Hello World, JMSExpiration, ttl); // sleep just a little Thread.sleep(2000); // use timeout in case running on slow box Exchange bar = consumer.receive(activemq:queue:bar, 1); assertNotNull(Should be a message on queue, bar); template.send(activemq:queue:foo, bar); assertMockEndpointsSatisfied(); } @Test public void testInOnlyJMSExpirationNoMessage() throws Exception { MockEndpoint mock = getMockEndpoint(mock:result); mock.expectedMessageCount(1); long ttl = System.currentTimeMillis() + 2000; template.sendBodyAndHeader(activemq:queue:bar?preserveMessageQos=true, Hello World, JMSExpiration, ttl); // sleep more so the message is expired Thread.sleep(5000); Exchange bar = consumer.receiveNoWait(activemq:queue:bar); assertNull(Should NOT be a message on queue, bar); template.sendBody(activemq:queue:foo, Hello World); assertMockEndpointsSatisfied(); } protected RouteBuilder createRouteBuilder() throws Exception { return new RouteBuilder() { public void configure() throws Exception { from(activemq:queue:foo) .to(mock:result); } }; } Check what you do differently... Best, Christian - Software Integration Specialist Apache Camel committer: https://camel.apache.org/team V.P. Apache Camel: https://www.apache.org/foundation/ Apache Member: https://www.apache.org/foundation/members.html https://www.linkedin.com/pub/christian-mueller/11/551/642 On Wed, Jul 24, 2013 at 4:42 PM, prabumc...@gmail.com prabumc...@gmail.comwrote: Hi Chris, Thanks so much for the information. I have tried different property but it did not work. Please find my code below. *public static final String CONSUMER_TEST_QNAME = activemq:queue:ConsumerTestHandler?jmsMessageType=TextpreserveMessageQos=true; * * * *public static final String PRODUCER_TEST_QNAME = activemq:queue:ProducerTestHandler?jmsMessageType=TextpreserveMessageQos=true; * ** *public static final String MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME = activemq:queue:Inbound.Memos.Consumer.Test;* * * *public static final String MESSAGING_TEST_PRODUCER_TYPE_SPECIFIC_QNAME = activemq:queue:Inbound.Memos.Producer.Test;* from(*MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME*).process(new Processor() { public void process(Exchange exchange) throws Exception { } .setHeader(MEMOS_TARGET_SERVER,header(MASTER_HANDLER)) .setHeader(JMSExpiration,constant(EXPIRY_TIME)) .to(CONSUMER_TEST_QNAME) .setHeader(MEMOS_TARGET_SERVER, header(SLAVE_HANDLER)) .setHeader(JMSExpiration,constant(EXPIRY_TIME)) .to(CONSUMER_TEST_QNAME) .end(); But,messages not expiring Please kindly help me *Thanks* Prabu.N On Wed, Jul 24, 2013 at 1:46 AM, Christian Mueller [via Camel] ml-node+s465427n5736163...@n5.nabble.com wrote: It's not really so difficult to find an example, if you spend only a few minutes: https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java;h=52b430b17a7ffc0ca977864ea8c6238050f90a57;hb=HEAD Best, Christian - Software Integration Specialist Apache Camel committer: https://camel.apache.org/team V.P. Apache Camel: https://www.apache.org/foundation/ Apache Member: https://www.apache.org/foundation/members.html https://www.linkedin.com/pub/christian-mueller/11/551/642 -- If you reply to this email, your message will be added to the discussion below: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5736163.html To unsubscribe from Camel routing issue, click here http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5736224.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue
. .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.RecipientListDefinitionorg.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=nodenode=5730920i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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=nodenode=5731013i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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 herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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
Re: Camel routing issue
/SendEmail.jtp?type=nodenode=5730920i=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.RecipientListDefinitionorg.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=nodenode=5730920i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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=nodenode=5731013i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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 herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble
Re: Camel routing issue
[via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5731013i=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=nodenode=5730920i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730920i=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.RecipientListDefinitionorg.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=nodenode=5730920i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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=nodenode=5731013i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- Thanks Regards Prabu.N
Re: Camel routing issue
. model.ChoiceDefinition .otherwise() ^ On Mon, Apr 15, 2013 at 8:55 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5731013i=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=nodenode=5730920i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730920i=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.RecipientListDefinitionorg.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=nodenode=5730920i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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=nodenode=5731013i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails
Re: Camel routing issue
It's not really so difficult to find an example, if you spend only a few minutes: https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java;h=52b430b17a7ffc0ca977864ea8c6238050f90a57;hb=HEAD Best, Christian - Software Integration Specialist Apache Camel committer: https://camel.apache.org/team V.P. Apache Camel: https://www.apache.org/foundation/ Apache Member: https://www.apache.org/foundation/members.html https://www.linkedin.com/pub/christian-mueller/11/551/642
Re: Camel routing issue
().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.RecipientListDefinitionorg.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=nodenode=5730920i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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=nodenode=5731013i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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 herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5731423.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue
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.RecipientListDefinitionorg.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=nodenode=5730920i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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=nodenode=5731013i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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 herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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.
Re: Camel routing issue
Hi If no destinations is returned, then the message is not routed anywhere. On Tue, Apr 16, 2013 at 3:44 PM, prabumc...@gmail.com prabumc...@gmail.com wrote: *One quick question.* from(activemq:queue:HHH.InboundQueue).multicast().beanRef(recipientsGenerator) @RecipientList() public SetString routeTo(Exchange ex) { final SetString destinations = new HashSetString(); //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 prabumc...@gmail.com 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.RecipientListDefinitionorg.apache.camel. model.ChoiceDefinition .otherwise() ^ On Mon, Apr 15, 2013 at 8:55 PM, Claus Ibsen-2 [via Camel] ml-node+s465427n5730920...@n5.nabble.com 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=nodenode=5730920i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730920i=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.RecipientListDefinitionorg.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=nodenode=5730920i=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: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5730920.html To unsubscribe from Camel routing issue, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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
Re: Camel routing issue
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] ml-node+s465427n573101...@n5.nabble.com 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=nodenode=5731013i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5731013i=1 wrote: *One quick question.* from(activemq:queue:HHH.InboundQueue).multicast().beanRef(recipientsGenerator) @RecipientList() public SetString routeTo(Exchange ex) { final SetString destinations = new HashSetString(); //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=nodenode=5731013i=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.RecipientListDefinitionorg.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=nodenode=5731013i=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=nodenode=5730920i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730920i=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.RecipientListDefinitionorg.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=nodenode=5730920i=2 Web: http://fusesource.com
Re: Camel routing issue
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=nodenode=5730920i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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=nodenode=5731013i=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 http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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.
Re: Camel routing issue
*One quick question.* from(activemq:queue:HHH.InboundQueue).multicast().beanRef(recipientsGenerator) @RecipientList() public SetString routeTo(Exchange ex) { final SetString destinations = new HashSetString(); //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 prabumc...@gmail.com 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.RecipientListDefinitionorg.apache.camel. model.ChoiceDefinition .otherwise() ^ On Mon, Apr 15, 2013 at 8:55 PM, Claus Ibsen-2 [via Camel] ml-node+s465427n5730920...@n5.nabble.com 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=nodenode=5730920i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730920i=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.RecipientListDefinitionorg.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=nodenode=5730920i=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: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5730920.html To unsubscribe from Camel routing issue, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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.
Re: Camel routing issue
/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase
Re: Camel routing issue
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.RecipientListDefinitionorg.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.
Re: Camel routing issue
* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here . NAML
Re: Camel routing issue
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, prabumc...@gmail.com prabumc...@gmail.com 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.RecipientListDefinitionorg.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: cib...@redhat.com Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen
Re: Camel routing issue
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.RecipientListDefinitionorg.apache.camel. model.ChoiceDefinition .otherwise() ^ On Mon, Apr 15, 2013 at 8:55 PM, Claus Ibsen-2 [via Camel] ml-node+s465427n5730920...@n5.nabble.com 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=nodenode=5730920i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730920i=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.RecipientListDefinitionorg.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=nodenode=5730920i=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: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5730920.html To unsubscribe from Camel routing issue, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730926.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue
in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730118.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=nodenode=5730166i=7 Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen -- Claus Ibsen - Red Hat, Inc. FuseSource is now part of Red Hat Email: [hidden email] http://user/SendEmail.jtp?type=nodenode=5730166i=8 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-tp5730094p5730166.html To unsubscribe from Camel routing issue, click here http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730194.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Thanks Regards Prabu.N -- Thanks Regards Prabu.N -- Thanks Regards Prabu.N -- Thanks Regards Prabu.N
Re: Camel routing issue
Claus´ book (p. 44ff) which has a perfect example or http://camel.apache.org/content-based-router.html (just replace the direct: with your queues). If you need to fire your messages to multiple queues: http://camel.apache.org/publish-subscribe-channel.html shows you the various ways. When you get the concepts you can just lego them together. Regards, Thomas. Am 30.03.2013 um 19:05 schrieb [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=1: Hi Claus, Thanks so much Clus for help.It is working now. I need your guidance for the following requirement. 1.I have one *inbound queue* it will receive message frequently from my application. 2.From *inbound queue* i need camel routing to move message from another *message based inbound queue* based on message header value. 3.From *message based inbound queue *i* *need camel routing to move message to *one or more outbound queue *based on message content* * I need *camel java DSL*sample code for above requirement.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase
Re: Camel routing issue
1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730118.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=nodenode=5730166i=7 Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen -- Claus Ibsen - Red Hat, Inc. FuseSource is now part of Red Hat Email: [hidden email]http://user/SendEmail.jtp?type=nodenode=5730166i=8 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
Re: Camel routing issue
=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=1: Hi Claus, Thanks so much Clus for help.It is working now. I need your guidance for the following requirement. 1.I have one *inbound queue* it will receive message frequently from my application. 2.From *inbound queue* i need camel routing to move message from another *message based inbound queue* based on message header value. 3.From *message based inbound queue *i* *need camel routing to move message to *one or more outbound queue *based on message content* * I need *camel java DSL*sample code for above requirement.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml
Re: Camel routing issue
] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730166i=6 wrote: Hi, you could start by reading Claus´ book (p. 44ff) which has a perfect example or http://camel.apache.org/content-based-router.html(just replace the direct: with your queues). If you need to fire your messages to multiple queues: http://camel.apache.org/publish-subscribe-channel.html shows you the various ways. When you get the concepts you can just lego them together. Regards, Thomas. Am 30.03.2013 um 19:05 schrieb [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=1: Hi Claus, Thanks so much Clus for help.It is working now. I need your guidance for the following requirement. 1.I have one *inbound queue* it will receive message frequently from my application. 2.From *inbound queue* i need camel routing to move message from another *message based inbound queue* based on message header value. 3.From *message based inbound queue *i* *need camel routing to move message to *one or more outbound queue *based on message content* * I need *camel java DSL*sample code for above requirement.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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
Re: Camel routing issue
. * .when(header(Type).isNotNull()) .to(activemq.Inbound.+header(Type)) * Example:If queue type is test,It should forward to *Inbound.test* queue. Above example i tried,but it did not worked,created queue something like this *Inbound.header(type)* *Question2*: from(direct:a) .multicast().to(direct:b, direct:c, direct:d); Based on messages header and content type i want forward to different queue. condition will be *OR *and *AND*.How can i do that like above example.* * Thanks in advance* * *Regards* Prabu.N On Sun, Mar 31, 2013 at 2:43 AM, Walzer, Thomas [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730166i=6 wrote: Hi, you could start by reading Claus´ book (p. 44ff) which has a perfect example or http://camel.apache.org/content-based-router.html(just replace the direct: with your queues). If you need to fire your messages to multiple queues: http://camel.apache.org/publish-subscribe-channel.html shows you the various ways. When you get the concepts you can just lego them together. Regards, Thomas. Am 30.03.2013 um 19:05 schrieb [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=1: Hi Claus, Thanks so much Clus for help.It is working now. I need your guidance for the following requirement. 1.I have one *inbound queue* it will receive message frequently from my application. 2.From *inbound queue* i need camel routing to move message from another *message based inbound queue* based on message header value. 3.From *message based inbound queue *i* *need camel routing to move message to *one or more outbound queue *based on message content* * I need *camel java DSL*sample code for above requirement.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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
Re: Camel routing issue
iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730118.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=nodenode=5730166i=7 Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen -- Claus Ibsen - Red Hat, Inc. FuseSource is now part of Red Hat Email: [hidden email] http://user/SendEmail.jtp?type=nodenode=5730166i=8 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-tp5730094p5730166.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730194.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=nodenode=5730195i=4 Web: http
Re: Camel routing issue
camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730118.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=nodenode=5730166i=7 Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen -- Claus Ibsen - Red Hat, Inc. FuseSource is now part of Red Hat Email: [hidden email] http://user/SendEmail.jtp?type=nodenode=5730166i=8 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
Re: Camel routing issue
java DSL*sample code for above requirement.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730118.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: cib...@redhat.com Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen -- Claus Ibsen - Red Hat, Inc. FuseSource is now part of Red Hat Email: cib...@redhat.com Web: http://fusesource.com Twitter: davsclaus Blog
Re: Camel routing issue
them together. Regards, Thomas. Am 30.03.2013 um 19:05 schrieb [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=1: Hi Claus, Thanks so much Clus for help.It is working now. I need your guidance for the following requirement. 1.I have one *inbound queue* it will receive message frequently from my application. 2.From *inbound queue* i need camel routing to move message from another *message based inbound queue* based on message header value. 3.From *message based inbound queue *i* *need camel routing to move message to *one or more outbound queue *based on message content* * I need *camel java DSL*sample code for above requirement.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace
Re: Camel routing issue
, Walzer, Thomas [via Camel] [hidden email]http://user/SendEmail.jtp?type=nodenode=5730152i=5 wrote: Hi, you could start by reading Claus´ book (p. 44ff) which has a perfect example or http://camel.apache.org/content-based-router.html (just replace the direct: with your queues). If you need to fire your messages to multiple queues: http://camel.apache.org/publish-subscribe-channel.html shows you the various ways. When you get the concepts you can just lego them together. Regards, Thomas. Am 30.03.2013 um 19:05 schrieb [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=1: Hi Claus, Thanks so much Clus for help.It is working now. I need your guidance for the following requirement. 1.I have one *inbound queue* it will receive message frequently from my application. 2.From *inbound queue* i need camel routing to move message from another *message based inbound queue* based on message header value. 3.From *message based inbound queue *i* *need camel routing to move message to *one or more outbound queue *based on message content* * I need *camel java DSL*sample code for above requirement.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.html Sent from the Camel - Users mailing list archive at Nabble.com
Re: Camel routing issue
queue name,But what i want is below. * .when(header(Type).isNotNull()) .to(activemq.Inbound.+header(Type)) * Example:If queue type is test,It should forward to *Inbound.test* queue. Above example i tried,but it did not worked,created queue something like this *Inbound.header(type)* *Question2*: from(direct:a) .multicast().to(direct:b, direct:c, direct:d); Based on messages header and content type i want forward to different queue. condition will be *OR *and *AND*.How can i do that like above example.* * Thanks in advance* * *Regards* Prabu.N On Sun, Mar 31, 2013 at 2:43 AM, Walzer, Thomas [via Camel] [hidden email]http://user/SendEmail.jtp?type=nodenode=5730152i=5 wrote: Hi, you could start by reading Claus´ book (p. 44ff) which has a perfect example or http://camel.apache.org/content-based-router.html (just replace the direct: with your queues). If you need to fire your messages to multiple queues: http://camel.apache.org/publish-subscribe-channel.html shows you the various ways. When you get the concepts you can just lego them together. Regards, Thomas. Am 30.03.2013 um 19:05 schrieb [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=1: Hi Claus, Thanks so much Clus for help.It is working now. I need your guidance for the following requirement. 1.I have one *inbound queue* it will receive message frequently from my application. 2.From *inbound queue* i need camel routing to move message from another *message based inbound queue* based on message header value. 3.From *message based inbound queue *i* *need camel routing to move message to *one or more outbound queue *based on message content* * I need *camel java DSL*sample code for above requirement.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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
Re: Camel routing issue
*message based inbound queue *i* *need camel routing to move message to *one or more outbound queue *based on message content* * I need *camel java DSL*sample code for above requirement.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730118.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=nodenode=5730166i=7 Web: http://fusesource.com Twitter
Re: Camel routing issue
: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730118.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: cib...@redhat.com Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen
Re: Camel routing issue
1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730118.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: cib...@redhat.com Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen
Re: Camel routing issue
.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730118.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=nodenode=5730134i=5 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-tp5730094p5730134.html To unsubscribe from Camel routing issue, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro
Re: Camel routing issue
for the following requirement. 1.I have one *inbound queue* it will receive message frequently from my application. 2.From *inbound queue* i need camel routing to move message from another *message based inbound queue* based on message header value. 3.From *message based inbound queue *i* *need camel routing to move message to *one or more outbound queue *based on message content* * I need *camel java DSL*sample code for above requirement.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.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-tp5730094p5730116.html To unsubscribe from Camel routing issue, click here . NAML http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730118.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
Re: Camel routing issue
Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, prabumc...@gmail.com prabumc...@gmail.com wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns=http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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: cib...@redhat.com Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen
Re: Camel routing issue
Hi Claus, Thanks so much Clus for help.It is working now. I need your guidance for the following requirement. 1.I have one *inbound queue* it will receive message frequently from my application. 2.From *inbound queue* i need camel routing to move message from another *message based inbound queue* based on message header value. 3.From *message based inbound queue *i* *need camel routing to move message to *one or more outbound queue *based on message content* * I need *camel java DSL*sample code for above requirement.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] ml-node+s465427n5730109...@n5.nabble.com wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email]http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns=http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5730109.html To unsubscribe from Camel routing issue, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue
Hi, you could start by reading Claus´ book (p. 44ff) which has a perfect example or http://camel.apache.org/content-based-router.html (just replace the direct: with your queues). If you need to fire your messages to multiple queues: http://camel.apache.org/publish-subscribe-channel.html shows you the various ways. When you get the concepts you can just lego them together. Regards, Thomas. Am 30.03.2013 um 19:05 schrieb prabumc...@gmail.com prabumc...@gmail.com: Hi Claus, Thanks so much Clus for help.It is working now. I need your guidance for the following requirement. 1.I have one *inbound queue* it will receive message frequently from my application. 2.From *inbound queue* i need camel routing to move message from another *message based inbound queue* based on message header value. 3.From *message based inbound queue *i* *need camel routing to move message to *one or more outbound queue *based on message content* * I need *camel java DSL*sample code for above requirement.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] ml-node+s465427n5730109...@n5.nabble.com wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email]http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns=http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094p5730109.html To unsubscribe from Camel routing issue, click herehttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=5730094code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczMDA5NHw4OTY0MTU3ODg= . NAMLhttp://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=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-tp5730094p5730115.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel routing issue
Thanks Walzer.. * * *Queston1: * *Example* .when(header(foo).isEqualTo(bar)) .to(direct:b) In my case i have to add more than 80 condition and forwards to 80 different queues. Above example i can only hard-code queue name,But what i want is below. * .when(header(Type).isNotNull()) .to(activemq.Inbound.+header(Type)) * Example:If queue type is test,It should forward to *Inbound.test* queue. Above example i tried,but it did not worked,created queue something like this *Inbound.header(type)* *Question2*: from(direct:a) .multicast().to(direct:b, direct:c, direct:d); Based on messages header and content type i want forward to different queue. condition will be *OR *and *AND*.How can i do that like above example.* * Thanks in advance* * *Regards* Prabu.N On Sun, Mar 31, 2013 at 2:43 AM, Walzer, Thomas [via Camel] ml-node+s465427n5730116...@n5.nabble.com wrote: Hi, you could start by reading Claus´ book (p. 44ff) which has a perfect example or http://camel.apache.org/content-based-router.html (just replace the direct: with your queues). If you need to fire your messages to multiple queues: http://camel.apache.org/publish-subscribe-channel.html shows you the various ways. When you get the concepts you can just lego them together. Regards, Thomas. Am 30.03.2013 um 19:05 schrieb [hidden email]http://user/SendEmail.jtp?type=nodenode=5730116i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=1: Hi Claus, Thanks so much Clus for help.It is working now. I need your guidance for the following requirement. 1.I have one *inbound queue* it will receive message frequently from my application. 2.From *inbound queue* i need camel routing to move message from another *message based inbound queue* based on message header value. 3.From *message based inbound queue *i* *need camel routing to move message to *one or more outbound queue *based on message content* * I need *camel java DSL*sample code for above requirement.* * * * *Thanks in advance* On Sat, Mar 30, 2013 at 3:10 PM, Claus Ibsen-2 [via Camel] [hidden email] http://user/SendEmail.jtp?type=nodenode=5730116i=2 wrote: Hi Do as the exception tells you. Check route 2. You route from Inbound.SSS.TestEvent. And that is now know to Camel. Maybe you need to add activemq: as prefix so its activemq:Inbound.SSS.TestEvent. On Fri, Mar 29, 2013 at 7:01 PM, [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=0 [hidden email] http://user/SendEmail.jtp?type=nodenode=5730109i=1 wrote: I have activemmq Project in that i have following requirement 1.Move message from Inbound queue to type based inbound queue. 2.Move message from Message type inbound queue to outbound queue I have created two bean for to achieve this. 1.one for move from inbound to message type inbound queue 2.one for move from inbound to outbound queue. I have following entry in camel.xml camelContext id=camel xmlns= http://camel.apache.org/schema/spring; routeBuilder ref=routeBuilder / routeBuilder ref=routeBuilder1 / /camelContext bean id=routeBuilder class=com.camel.routes.SinglecastRouteBuilder/ bean id=recipientsGenerator class=com.camel.routes.TypeSpecificListBean/ bean id=routeBuilder1 class=com.camel.routes.MulticastRouteBuilder/ bean id=recipientsGenerator1 class=com.camel.routes.RecipientListBean/ When i run application i am getting following error. * java.lang.Exception: org.apache.camel.RuntimeCamelException: org.apache.camel.Fa iledToCreateRouteException: Failed to create route route2: Route[[From[Inbound.G MD.TestEvent]] - [Multicast[[Bean[ref:... because of No endpoint could be found for: Inbound.SSS.TestEvent, please check your classpath contains the needed Cam el component jar.* I am not sure i am missing any configuration,Please kindly help me -- View this message in context: http://camel.465427.n5.nabble.com/Camel-routing-issue-tp5730094.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=nodenode=5730109i=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_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml