No consumers available on endpoint: Endpoint[direct:processMsg]

2009-04-20 Thread Henric Hedin
Hi, I have a problem which occurs when I have a Route which looks like this: // initiated from queue from("jms:queue:SOURCE_QUEUE"). to("direct:processMsg"); // initiated from file from("file://inbox). to("direct:processMsg"); // Main flow from("direct:processMsg") .process("...") .to("valid

Re: No consumers available on endpoint: Endpoint[direct:processMsg]

2009-04-20 Thread Henric Hedin
Thank you, this simple solution (of course) worked like a charm! My DSL become a bit backwards, but guess I have to live with that :) /Henric On Mon, Apr 20, 2009 at 10:58 AM, Claus Ibsen wrote: > Hi > > Can you not just reorder the routes? Camel should process them in the > order they are def

Re: Resequencer pattern does not work with the StreamRequencer config

2009-04-20 Thread Martin Krasser
Hi Nawaz, Some comments to your code: - Technically you should be able to get the code working using constant(Long.valueOf("1000")) but this doesn't resequence the message because all will have the same sequence number - How to customize the resequencer using sequence numbers other than long

Re: thoughts on the method names for the requestBody and requestBodyAndHeader etc

2009-04-20 Thread Claus Ibsen
On Mon, Apr 20, 2009 at 11:29 AM, Roman Kalukiewicz wrote: > OK Claus, I'm somehow convinced, but what would you say about > > sendInOnly() > sendInOut() Yeah and we can have a generic send for the remaining 5% use cases, where you can set the pattern and whatnot. > > This way there is no problem

Re: thoughts on the method names for the requestBody and requestBodyAndHeader etc

2009-04-20 Thread Roman Kalukiewicz
OK Claus, I'm somehow convinced, but what would you say about sendInOnly() sendInOut() This way there is no problem at all with understanding what it does and the name is short and clear. Another thing is those headers that I believe should be in overloaded signatures and shouldn't be in method

Re: Resequencer pattern does not work with the StreamRequencer config

2009-04-20 Thread Claus Ibsen
Hi Are you using Camel 1.x? In Camel 2.0 it should use the Camel type converter system so it can automatic convert it to a Long type that the resequencer requires. In Camel 1.x you must provide a Long type as it uses the regular java type converter = (Long). And yes we should probably propagate

Resequencer pattern does not work with the StreamRequencer config

2009-04-20 Thread Nawaz Ahmed
Hi all, I was going through the Resequencer camel component available in the link: http://camel.apache.org/resequencer.html On trying the resequencer camel component with the StreamResequencer config with the code below: from("jms:queue:nq1"). convertBodyTo(String.c

Re: No consumers available on endpoint: Endpoint[direct:processMsg]

2009-04-20 Thread Claus Ibsen
On Mon, Apr 20, 2009 at 11:13 AM, Henric Hedin wrote: > Thank you, this simple solution (of course) worked like a charm! > > My DSL become a bit backwards, but guess I have to live with that :) You can split it into multiple files and order them using the XML configuration. But maybe we need to

Re: Resequencer pattern does not work with the StreamRequencer config

2009-04-20 Thread Claus Ibsen
BTW the code you have can work if you change constant("1000") to a long type, something like this: constant(Long.valueOf("1000")) On Mon, Apr 20, 2009 at 8:46 AM, Nawaz Ahmed wrote: > Hi all, > >   I was going through the Resequencer camel component available in the > link: http://camel.apache.

Re: No consumers available on endpoint: Endpoint[direct:processMsg]

2009-04-20 Thread Claus Ibsen
Hi Can you not just reorder the routes? Camel should process them in the order they are defined. On Mon, Apr 20, 2009 at 10:50 AM, Henric Hedin wrote: > Hi, > > I have a problem which occurs when I have a Route which looks like this: > > // initiated from queue > from("jms:queue:SOURCE_QUEUE").

Re: Aggregator batchTimeout

2009-04-20 Thread tmi
Frank Schwarz wrote: > > How do you read it? > (a) The aggregation is aborted after the batchTimeout, leading to possibly > fragmentary messages. The aggregation is started, when the first message > is available. > (b) The aggregator waits the batchTimeout timespan and then begins the > aggregat

Re: Multiple consumers getting created in custom endpoint

2009-04-20 Thread Willem Jiang
Hi Manish, I just created a JIRA[1] for this issue, and committed a quick fix for it. I also did a quick fix for the Camel trunk, please feel free to verify it with Camel 2.0. We will get it out soon, maybe this Quarter :) [1] https://issues.apache.org/activemq/browse/CAMEL-1544 Willem Willem J

Re: Aggregator batchTimeout

2009-04-20 Thread Claus Ibsen
On Mon, Apr 20, 2009 at 1:22 PM, tmi wrote: > > > Frank Schwarz wrote: >> >> How do you read it? >> (a) The aggregation is aborted after the batchTimeout, leading to possibly >> fragmentary messages. The aggregation is started, when the first message >> is available. >> (b) The aggregator waits th

Visio stencil of Camel EIP (work completed)

2009-04-20 Thread Charles Moulliard
Hi, I have added the new visio stencil file relooked of the EIP patterns to respect the color of Camel : Sand. http://cwiki.apache.org/CAMEL/enterprise-integration-patterns.html(resources section) All the EIP icons have been relooked ;-) Regards, Charles SOA Architect

Re: Aggregator batchTimeout

2009-04-20 Thread Frank Schwarz
Torsten, thank you for confirming my findings. So, essentially the aggregator waits the specified batchTimeout milliseconds, aggregates whatever it finds on the queue and then waits for the next round. This is not quite what I was expecting - or to put it differently: Is there a way to aggregate

Accessing header variables in XQuery endpoints

2009-04-20 Thread rogster
I need to access camel context header variables in my XQuery endpoint. So in my context file i do something to this effect: bar where my xquery does something very simple like this: { $in.headers.foo } // I also tried just $foo etc... Always with an error message that the variable wasn

Camel Guice Integration

2009-04-20 Thread adambender
I am working on a project with heavy Guice integration and we are now developing a messaging system and have decided to go with ActiveMQ+Camel+Guice. I have a good understanding of the producer, consumer and JMSComponent injection, but I haven't been able to figure out the Guice way of bringing u

JPA component in a JEE5 environment

2009-04-20 Thread Frank Schwarz
Hi, I tried to make use of the jpa component. It seems to be, however, that this component tries to create an EntityManagerFactory for its own - not a good idea in a JEE5 environment. Is there any way to let Spring do the resource-configuration / -lookup stuff? Cheers, Frank (Camel 2.0M1, JBos

Re: JPA component in a JEE5 environment

2009-04-20 Thread Claus Ibsen
Hi Yeah sure overload the jpa component and set the entity manager factory. On Tue, Apr 21, 2009 at 7:39 AM, Frank Schwarz wrote: > > Hi, > > I tried to make use of the jpa component. It seems to be, however, that this > component tries to create an EntityManagerFactory for its own - no