date:20130330

endpoint without consumer

2013-03-30 Thread takidean

when i  use to select some rows from a database i get one error and this is
my code:

public static void main(String[] args) throws Exception {

// TODO Auto-generated method stub
//DataSource dd;
 DriverManagerDataSource db = new DriverManagerDataSource();
 
  db.setDriverClassName(com.mysql.jdbc.Driver);
db.setUrl(jdbc:mysql://localhost:3306/examen);
db.setUsername(root);
db.setPassword();
SimpleRegistry re= new SimpleRegistry();
re.put(ds,db);
// JdbcComponent jd = new JdbcComponent();
//jd.setDataSource(ds);
//jd.createEndpoint(jdbc:mysql://localhost:3306/examen);
ConnectionFactory connectionFactory =new
ActiveMQConnectionFactory(vm://localhost);
CamelContext context = new DefaultCamelContext(re);
context.addComponent(jms,JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));

 final Endpoint endpoint = context.getEndpoint(direct:hello);
 Exchange exchange = endpoint.createExchange();
 exchange.getIn().setBody(SELECT * FROM `examen`.`user` WHERE `user`.`name`
= 'tt');
 ProducerTemplate template = context.createProducerTemplate();
 Exchange out = template.send(endpoint, exchange);
context.addRoutes(new RouteBuilder() {

@Override
public void configure() throws Exception {
from(direct:hello)
.to(jdbc:ds); 
}
});




ArrayListHashMaplt;String, Object data =
out.getIn().getBody(ArrayList.class);
/*assertNotNull(out body could not be converted to an ArrayList - was: 
+ out.getOut().getBody(), data);*/
HashMapString, Object row = data.get(0);
//assertEquals(2, data.size());
  //HashMapString, Object row = data.get(0);
System.out.println(le nom est +row.get(lastname)); 
//assertEquals(cust1, row.get(ID));
//assertEquals(jstrachan, row.get(NAME));
//row = data.get(1);
//assertEquals(cust2, row.get(ID));
//assertEquals(nsandhu, row.get(NAME));
context.start();

Thread.sleep(1);
context.stop();


}

}



/*errors***/
[  main] DriverManagerDataSourceINFO  Loaded
JDBC driver: com.mysql.jdbc.Driver
[  main] DefaultTypeConverter   INFO  Loaded
172 type converters
[  main] ManagementStrategyFactory  INFO  JMX
enabled.
[  main] DirectProducer WARN  No
consumers available on endpoint: Endpoint[direct://hello] to process:
Exchange[Message: SELECT * FROM `examen`.`user` WHERE `user`.`name` = 'tt']
Exception in thread main java.lang.NullPointerException
at taki.fin.Cntx.main(Cntx.java:101)



--
View this message in context: 
http://camel.465427.n5.nabble.com/endpoint-without-consumer-tp5730093.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: endpoint without consumer

2013-03-30 Thread Christian Müller

You have to start your route before you send a message via the producer
template.

Sent from a mobile device
Am 30.03.2013 08:41 schrieb takidean takide...@hotmail.fr:

 when i  use to select some rows from a database i get one error and this is
 my code:

 public static void main(String[] args) throws Exception {

 // TODO Auto-generated method stub
 //DataSource dd;
  DriverManagerDataSource db = new
 DriverManagerDataSource();

   db.setDriverClassName(com.mysql.jdbc.Driver);
 db.setUrl(jdbc:mysql://localhost:3306/examen);
 db.setUsername(root);
 db.setPassword();
 SimpleRegistry re= new SimpleRegistry();
 re.put(ds,db);
 // JdbcComponent jd = new JdbcComponent();
 //jd.setDataSource(ds);
 //jd.createEndpoint(jdbc:mysql://localhost:3306/examen);
 ConnectionFactory connectionFactory =new
 ActiveMQConnectionFactory(vm://localhost);
 CamelContext context = new DefaultCamelContext(re);

 context.addComponent(jms,JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));

  final Endpoint endpoint = context.getEndpoint(direct:hello);
  Exchange exchange = endpoint.createExchange();
  exchange.getIn().setBody(SELECT * FROM `examen`.`user` WHERE
 `user`.`name`
 = 'tt');
  ProducerTemplate template = context.createProducerTemplate();
  Exchange out = template.send(endpoint, exchange);
 context.addRoutes(new RouteBuilder() {

 @Override
 public void configure() throws Exception {
 from(direct:hello)
 .to(jdbc:ds);
 }
 });




 ArrayListHashMaplt;String, Object data =
 out.getIn().getBody(ArrayList.class);
 /*assertNotNull(out body could not be converted to an ArrayList - was: 
 + out.getOut().getBody(), data);*/
 HashMapString, Object row = data.get(0);
 //assertEquals(2, data.size());
   //HashMapString, Object row = data.get(0);
 System.out.println(le nom est +row.get(lastname));
 //assertEquals(cust1, row.get(ID));
 //assertEquals(jstrachan, row.get(NAME));
 //row = data.get(1);
 //assertEquals(cust2, row.get(ID));
 //assertEquals(nsandhu, row.get(NAME));
 context.start();

 Thread.sleep(1);
 context.stop();


 }

 }



 /*errors***/
 [  main] DriverManagerDataSourceINFO
  Loaded
 JDBC driver: com.mysql.jdbc.Driver
 [  main] DefaultTypeConverter   INFO
  Loaded
 172 type converters
 [  main] ManagementStrategyFactory  INFO  JMX
 enabled.
 [  main] DirectProducer WARN  No
 consumers available on endpoint: Endpoint[direct://hello] to process:
 Exchange[Message: SELECT * FROM `examen`.`user` WHERE `user`.`name` = 'tt']
 Exception in thread main java.lang.NullPointerException
 at taki.fin.Cntx.main(Cntx.java:101)



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/endpoint-without-consumer-tp5730093.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

custom MDCUnitOfWork

2013-03-30 Thread samslara

Hello,
  I'm currently looking to implement logic very similar to MDCUnitOfWork,
the main difference being putting custom values into the MDC.  How would I
go about doing this?



--
View this message in context: 
http://camel.465427.n5.nabble.com/custom-MDCUnitOfWork-tp5730107.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: in camel-example-cxf-proxy demo which in camel distribution, how EnrichBean.enrich method was called

2013-03-30 Thread Claus Ibsen

On Fri, Mar 29, 2013 at 10:47 AM, lost_in rex173...@gmail.com wrote:
 hi all,

 I have post this issue on
 http://camel.465427.n5.nabble.com/in-camel-example-cxf-proxy-demo-which-in-camel-distribution-how-EnrichBean-enrich-method-was-called-td5729745.html
 http://camel.465427.n5.nabble.com/in-camel-example-cxf-proxy-demo-which-in-camel-distribution-how-EnrichBean-enrich-method-was-called-td5729745.html

 thanks Claus Ibsen-2's replay,he is a nice gay!!

 I follow his suggestion and read corresponding section, but i still can't
 find the answer.
 I also read cxf's data format's tips on
 http://camel.apache.org/cxf.html http://camel.apache.org/cxf.html

 following is my previous post's content:
 I am a newbie in camel,when I read the camel-example-cxf-proxy demo which in
 camel distribution,
  I confuse with EnrichBean.java file

 the source code of EnrichBean.java is very simple as follows:

 public class EnrichBean {

 public Document enrich(Document doc) {
 Node node = doc.getElementsByTagName(incidentId).item(0);
 String incident = node.getTextContent();

 // here we enrich the document by changing the incident id to
 another value
  // you can of course do a lot more in your use-case
 node.setTextContent(456);
 System.out.println(Incident was  + incident + , changed to 456);

 return doc;
 }
 }

 it was used in camel_config.xml as follows:


   bean id=enrichBean
 class=org.apache.camel.example.cxf.proxy.EnrichBean/


   camelContext xmlns=http://camel.apache.org/schema/spring;
 endpoint id=quot;callRealWebServicequot; uri=quot;lt;a
 href=quot;http://localhost:$quot;http://localhost:${real.port}/real-webservice?throwExceptionOnFailure=false/
 route

   from uri=cxf:bean:reportIncident?dataFormat=MESSAGE/

   to uri=log:input/

   to uri=bean:enrichBean/

   to ref=callRealWebService/

   to uri=log:output/
 /route

   /camelContext

 my question is: how EnrichBean.enrich method was called and why the
 parameter to enrich() is Document type?


You can omit specifying a method, and if you do so, then Camel has to
pick the method to use.
And for that it has an algorithm to do so. See those links I posted
before. Or check out Camel in Action, chapter 4, we have a diagram of
this algorithm explaining it in details.

 to uri=bean:enrichBean/

If the bean has only 1 method, its easy to pick, but when it has more
methods its harder. You can tell Camel which method to use, eg

 to uri=bean:enrichBean?method=enrich/


The type Document is from JDK which is an Object representation of
XML. We could also have used String instead, then we would get the XML
in a String. Camel uses its type converter to convert to the types of
the method signature.

But the Document type allows us to DOM API to enrich the message as
the code does.

But its your chose, you can do as you want.




 any reply is appriciate!



 --
 View this message in context: 
 http://camel.465427.n5.nabble.com/in-camel-example-cxf-proxy-demo-which-in-camel-distribution-how-EnrichBean-enrich-method-was-called-tp5730076.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

2013-03-30 Thread Claus Ibsen

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

Camel cannot store file !!

2013-03-30 Thread takidean

i want to send selected rows from a database to file this is my code
 camelContext trace=false xmlns=http://camel.apache.org/schema/spring;
route id=trigger-database
from uri=timer://webinar?delay=2amp;period=2/
setBody
constantSELECT * FROM `user` WHERE 1/constant
/setBody
to uri=jdbc:reportdb/
split
simple${body}/simple
to uri=file://src/data//
/split
/route
/camelContext

bean id=reportdb
class=org.springframework.jdbc.datasource.DriverManagerDataSource
property name=driverClassName value=com.mysql.jdbc.Driver/
property name=url value=jdbc:mysql://localhost:3306/examen/
property name=username value=root/
property name=password value=/
/bean



/beans

/**Error/
when i execute it i got this error

ERROR Failed delivery for (MessageId: ID-unknown-PC-2192-1364647676887-0-3
on ExchangeId: ID-unknown-PC-2192-1364647676887-0-4). Exhausted after
delivery attempt: 1 caught:
org.apache.camel.component.file.GenericFileOperationFailedException: Cannot
store file: src\data\ID-unknown-PC-2192-1364647676887-0-3
org.apache.camel.component.file.GenericFileOperationFailedException: Cannot
store file: src\data\ID-unknown-PC-2192-1364647676887-0-3



--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-cannot-store-file-tp5730110.html
Sent from the Camel - Users mailing list archive at Nabble.com.

spring-ws timeout question

2013-03-30 Thread Smith-John

Hi,

I wanted to create a camel route with which it is possible to invoke various
SOAP-WebServices.
I ended up with following:

from(direct:Invoke).recipientList(this.header(WSAddress));

and 

Document response = template.requestBodyAndHeader(direct:Invoke, request,
WSAddress, spring-ws: + address.toString(), Document.class);

For testing purpose I created a WS that needs about 5 minutes to response.
Calling it directly with SoapUI I'm getting of course a
/ERROR:java.net.SocketTimeoutException: Read timed out/.
But with posted camel route there isn't a timeout.

Now my question is how spring-ws component handles long running Web Services
concerning timeouts for example? What's the mechanism? Async or sync?
Callback? Or has spring-ws just a higher default timeout?
It would be nice if someone could explain it to me. 

With kind regards.




--
View this message in context: 
http://camel.465427.n5.nabble.com/spring-ws-timeout-question-tp5730111.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel routing issue

2013-03-30 Thread 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.

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:

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: Is there a DataFormat to convert XML string to XML Document?

2013-03-30 Thread Chris Wolf

Thanks - that's exactly what I needed.  Although I'm wondering when
you would select   .convertBodyTo(Class?)  vs. a DataFormat?

Thanks again,


Chris



On Fri, Mar 29, 2013 at 8:38 PM, Raul Kripalani r...@evosent.com wrote:
 .convertBodyTo(Document.class)

 Leverages a feature of Camel called Type Conversion.

 Raúl.

 Sent while on the move
 On 29 Mar 2013 22:40, Chris Wolf cwolf.a...@gmail.com wrote:

 I don't see any listed here:

 http://camel.apache.org/data-format.html

 ...but I find it hard to believe there isn't a way to convert a string
 to XML without creating a custom processor to parse string data from a
 web service.

 Thanks,

 Chris

Re: Camel routing issue

2013-03-30 Thread prabumc...@gmail.com

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

endpoint without consumer

Re: endpoint without consumer

custom MDCUnitOfWork

Re: in camel-example-cxf-proxy demo which in camel distribution, how EnrichBean.enrich method was called

Re: Camel routing issue

Camel cannot store file !!

spring-ws timeout question

Re: Camel routing issue

Re: Camel routing issue

Re: Is there a DataFormat to convert XML string to XML Document?

Re: Camel routing issue

11 matches

Site Navigation

Mail list logo

Footer information