Re: File consumer + POJO splitter

2010-04-14 Thread John Landahl
On Tue, Apr 13, 2010 at 7:26 PM, Willem Jiang wrote: > I think it should be a best practice to copy the inMessage header if return > a list of new created Messages within the split method. That may be, but how is it that /not/ doing this results in errors in the File component?

File consumer + POJO splitter

2010-04-13 Thread John Landahl
I've discovered strange behavior (at least to me) when using a file consumer connected to a POJO splitter. Here's my route: from("file:input"). split().method("fileSplitter", "split"). to("mock:out") If my POJO returns a list of newly created messages (via "new DefaultMessage(

Re: Polling Consumer question

2010-03-05 Thread John Landahl
On Fri, Mar 5, 2010 at 12:37 PM, Norman Maurer wrote: > just read my last comments .. > > http://old.nabble.com/Activemq-component-und-Delayer-ts27784918.html > > I think the selector is the way to go. I did, but I didn't see how selectors were any different from a Camel filter (the unintended ci

Re: Polling Consumer question

2010-03-05 Thread John Landahl
On Thu, Mar 4, 2010 at 9:19 PM, Claus Ibsen wrote: > John says at this thread > http://old.nabble.com/Activemq-component-und-Delayer-ts27784918.html > > That this questions is answered. But as the other person in that thread said, now we just have to wait for ActiveMQ 5.4. Reading through that t

Re: Activemq component und Delayer

2010-03-04 Thread John Landahl
On Thu, Mar 4, 2010 at 11:46 AM, Claus Ibsen wrote: > For example it appears as you can ask the producers to schedule delivery > http://activemq.apache.org/delay-and-schedule-message-delivery.html Claus, you may have answered the question on polling consumers that I just posted a minute ago. Thos

Polling Consumer question

2010-03-04 Thread John Landahl
Hi all, a quick question about writing a polling consumer. Is it possible to write a polling consumer with the Java DSL which polls a, queue periodically? Ideally I'd like to have the "delay" and "initialDelay" parameters of the File component, something like this: from("activemq:deferred?ini