Re: console for Fuse ESB

2010-04-07 Thread rguigsaad
Thank you, Is there any way to know , which message out corresponds to which message In. Is there any thing (header/id..) that remains the same in a message? regards. -- View this message in context: http://old.nabble.com/console-for-Fuse-ESB-tp28149718p28161729.html Sent from the Camel - Users

Re: FileComponent Camel 2.2

2010-04-07 Thread Nick Mitchell
So I tried that endpoint change again, I tried this already but no different. I finally got trace coming through and I did take a look at the source code and for some reason it's using this as an absolute path instead of a relative path. Is there any sort of override for that? 2010-04-07 09:19:

Re: FileComponent Camel 2.2

2010-04-07 Thread Nick Mitchell
We are setting FILE_ID in the header .setHeader(FILE_ID, SimpleLanguage.simple("${file:onlyname.noext}")) If I change the file expression to ${file:name.ext} then it does move it to .camel folder. I confused as to why it worked before and not now though. -- View this message in context: http:/

Re: FileComponent Camel 2.2

2010-04-07 Thread Claus Ibsen
Hi Could you post your route? I will then use it to reproduce the issue on my laptop. On Wed, Apr 7, 2010 at 10:45 AM, Nick Mitchell wrote: > > We are setting FILE_ID in the header > > .setHeader(FILE_ID, SimpleLanguage.simple("${file:onlyname.noext}")) > > If I change the file expression to ${

Re: ActiveMQ component and StreamMessage / BlobMessage

2010-04-07 Thread Claus Ibsen
Hi ActiveMQ does not output any javax.jms.StreamMessage, and therfore Camel have never needed to map it. And I also do not think javax.jms.StreamMessage is used very much? Anyone every used them? In terms of BlobMessage. Can you elaborate a bit? Is there anything in the BlobMessage API you needed

Re: FileComponent Camel 2.2

2010-04-07 Thread Nick Mitchell
from(cronTriggerExpression) .pollEnrich(ebookRemoteFTPIn,0) .idempotentConsumer(header("CamelFileName"),filenameRepository) .to(ebookIn); from(ebookIn) .process( new SetupChildRouteRuntime(metaRo

Re: ActiveMQ component and StreamMessage / BlobMessage

2010-04-07 Thread Norman Maurer
Hi Claus, thx for your response :) If you look at the documentation of BlobMessage how the message is send via the producer in activemq: http://activemq.apache.org/blob-messages.html So it would be useful if it would be possible to set the "URL" which is used by the activemq producer to send the

Re: ActiveMQ component and StreamMessage / BlobMessage

2010-04-07 Thread Norman Maurer
Maybe I should stopping getting on your nerves and just contribute a patch ;) Bye, Norman 2010/4/7 Norman Maurer : > Hi Claus, > > thx for your response :) > > If you look at the documentation of BlobMessage how the message is > send via the producer in activemq: > http://activemq.apache.org/blo

Aggregator2: completion size using expression doesn't work?

2010-04-07 Thread eugene hardbread
Hello I am trying to configure aggregator2 using completionSize with header expression: public class AggregatorTest extends CamelTestSupport{ @EndpointInject(uri = "mock:result") private MockEndpoint mockResult; @Override protected RouteBuilder createRouteBuilder() throws Excepti

Re: Aggregator2: completion size using expression doesn't work?

2010-04-07 Thread Claus Ibsen
Hi Can you try without groupExchanges(). To see if its the culprit of the issue. On Wed, Apr 7, 2010 at 12:47 PM, eugene hardbread wrote: > Hello > > I am trying to configure aggregator2 using completionSize with header > expression: > > public class AggregatorTest extends CamelTestSupport{ >  

How to Get MBean statistics For a Route, E.g. LastExchangeCompletedTimestamp

2010-04-07 Thread TRACK81
Hi, I am fairly new to Camel and strugling to get the statistic LastExchangeCompletedTimestamp for a "specific" route. I can get the statistic by using the getRoutes().get(2) using the following code: - Li

Re: How to Get MBean statistics For a Route, E.g. LastExchangeCompletedTimestamp

2010-04-07 Thread Claus Ibsen
CamelContext have a getRoute("id of the route") method. I think its in 2.2.0 also if not its in the next 2.3.0 release. In Java DSL you use .routeId("myRoute") to assign an id to a route. In Spring XML its just the id attribute on the tag. On Wed, Apr 7, 2010 at 1:42 PM, TRACK81 wrote: > > H

Re: FileComponent Camel 2.2

2010-04-07 Thread Nick Mitchell
I'm working through the source code and I can see boolean renamed = operations.renameFile(from.getAbsoluteFilePath(), to.getAbsoluteFilePath()); if (!renamed) { throw new GenericFileOperationFailedException("Cannot rename file: " + from + " to: " + to); } This implies

Re: FileComponent Camel 2.2

2010-04-07 Thread Claus Ibsen
Hi Try using the Tracer and/or add this logging to the end of your route .to("log:foo?showAll=true") It could be something in all your processors and whatnot which messes with the headers. I have created an unit test on my system and it works all the time. On Wed, Apr

Re: FileComponent Camel 2.2

2010-04-07 Thread Claus Ibsen
Hi I recon there is something in all you code that messes up the Camel headers. You could just try a very simple route to see if it can pickup the files and just move them to .camel Here is output from my test /System/Library/Frameworks/JavaVM.framework/Versions/1.5/Home/bin/java -Dfile.encoding

Re: How to Get MBean statistics For a Route, E.g. LastExchangeCompletedTimestamp

2010-04-07 Thread TRACK81
Hi Claus and thank you for the quick reply... I am using 2.2.0 and it its not in this release. Th curcumvent this i do as following: -- List routes = camelContext.getRoutes(); for(Route route : routes) { if(route.getI

Re: How to Get MBean statistics For a Route, E.g. LastExchangeCompletedTimestamp

2010-04-07 Thread Claus Ibsen
On Wed, Apr 7, 2010 at 2:29 PM, TRACK81 wrote: > > Hi Claus and thank you for the quick reply... I am using 2.2.0 and it its not > in this release. > Th curcumvent this i do as following: > > -- > List routes = camelContext.ge

Camel ActiveMQActivationSpec Component

2010-04-07 Thread greenbean
Has anyone created a component like the ActiveMQComponent, but one that utilizes the org.apache.activemq.ra.ActiveMQActivationSpec? Would it be difficult to do this? This version would not require polling behavior, correct? Thanks. -- View this message in context: http://old.nabble.com/Camel-

Re: Aggregator2: completion size using expression doesn't work?

2010-04-07 Thread eugene hardbread
I tried UseLatestAggregationStrategy and it worked. Code: public class AggregatorTest extends CamelTestSupport{ @EndpointInject(uri = "mock:result") private MockEndpoint mockResult; @Override protected RouteBuilder createRouteBuilder() throws Exception { return new RouteBu

Re: FileComponent Camel 2.2

2010-04-07 Thread Nick Mitchell
Many thanks for getting back to me. Right finally worked it out, I found that the CleanExchange processor at the end of the route was clearing the body and header of the exchange. If I remove this processor then it works fine again. I'm now trying to track down with the developer why they did tha

Eclipse and camel:run

2010-04-07 Thread Pitre, Russell
I just spent the last half day trying to figure out what I thought was a bug with a Camel route. I have a route that consumes multiple files from a ftp server and then a second route to process those files. Files were disappearing on me without any errors or debug messages, needless to say

Re: Eclipse and camel:run

2010-04-07 Thread Claus Ibsen
Hi Thanks for sharing this story. Yeah I can see why you would get really confused? And imagine powering on the computer the next day and it just worked :) On Wed, Apr 7, 2010 at 5:24 PM, Pitre, Russell wrote: > I just spent the last half day trying to figure out what I thought was a > bug with

Re: Camel with MINA 2.0

2010-04-07 Thread anandsk
would this netty have a support for acting as both producer and consumer to support async responses on a single connection?. Claus Ibsen-2 wrote: > > On Mon, Apr 5, 2010 at 1:18 PM, lujan99 wrote: >> >> Can I use MINA-component with MINA 2.0 ??? >> > > No camel-mina is using Mina 1.x. > > We

New Suggested Feature For Mina/Netty

2010-04-07 Thread Gareth Collins
Hello, In looking at the source for Netty/Mina, I see that it is assumed that if a consumer is desired a listener port is created, whilst if a producer is desired a client is created. Would it be possible in a subsequent release to relax this restriction (i.e. allowing a consumer to be a client,

Re: New Suggested Feature For Mina/Netty

2010-04-07 Thread anandsk
I have a similar requirement but only difference is I do have a message to send but I expect replies in asyncronous fashion. so I would vote for suggested feature. Though it is not elegant I am thinking of using this solution for now, may be it will work for you also and just send a blank message

Re: New Suggested Feature For Mina/Netty

2010-04-07 Thread anandsk
anandsk wrote: > > I have a similar requirement but only difference is I do have a message to > send but I expect async replies. so I would vote for suggested feature. > > Though it is not elegant I am thinking of using this solution for now, may > be it will work for you also and just send a

Re: New Suggested Feature For Mina/Netty

2010-04-07 Thread Gareth Collins
Thanks for the response. I considered what you suggested. I didn't know how to deal with multiple response messages per request though (I has understood that camel mina/netty components only supported "one request - one response"). thanks, Gareth anandsk wrote: > > I have a similar requiremen

Re: New Suggested Feature For Mina/Netty

2010-04-07 Thread anandsk
I think Mina(not camel-mina) has a background thread for receiving messages. you can try it out and see whether you get multiple messages using a simple route. Gareth Collins wrote: > > Thanks for the response. > > I considered what you suggested. I didn't know how to deal with multiple > res

Deploying as web app with jetty endpoint

2010-04-07 Thread jfaath
I've deployed my camel app as a web application in tomcat. Works great. The main starting point for my route is an http server endpoint using camel-jetty. So, it seems weird to me that tomcat starts and then starts a jetty instance. Is there any way to use the actual tomcat instance for this e

SEDA implementation

2010-04-07 Thread vcheruvu
Hi, I came across site about SEDA implementation, http://www.eecs.harvard.edu/~mdw/proj/seda/ . Does camel SEDA component follow this model? If it does, author stated that "It is also worth noting that a number of recent research papers have demonstrated that the SEDA prototype (in Java) perform

Re: Deploying as web app with jetty endpoint

2010-04-07 Thread Willem Jiang
Hi, If you don't want start the jetty engine, you can try to use the camel-servlet[1] component. [1]http://camel.apache.org/servlet.html Willem jfaath wrote: I've deployed my camel app as a web application in tomcat. Works great. The main starting point for my route is an http server end

Re: SEDA implementation

2010-04-07 Thread Willem Jiang
Hi Current camel-seda component is based on the queue with a thread pool to consume and produce the message. It's much like the SEDA that you found. But after went through the whole story, the write had some theories which made me think the research papers were doing the different things as we

Re: SEDA implementation

2010-04-07 Thread Claus Ibsen
Hi Yeah that SEDA paper is famous http://en.wikipedia.org/wiki/Staged_event-driven_architecture Its however written many years ago, when Java was not as evolved as today. Back in those days C++ was faster than Java. And today the story is different. Camel SEDA uses the JDK concurrency API and is