Aggregator

2010-02-23 Thread ronP12
Hello, I am polling a directory and only want to aggregate files if they meet a certain criteria (ie: camelfileparent = dir). This works fine, but, the exchange doesn't process for the messages that don't meet this criteria. My route is similar to: from("file:/tmp"). choice().when(header("Cam

Re: Number of failed exchanges not shown in JConsole

2010-01-29 Thread ronP12
the failed exchange. But if you redirect the message to a activemq > queue, you can browser the Queue size from the Jconsole. > > Willem > ronP12 wrote: >> Hi, >> I'm using the deadLetterChannel to redirect messages to a queue if the >> exchange fails. I'm

Number of failed exchanges not shown in JConsole

2010-01-28 Thread ronP12
Hi, I'm using the deadLetterChannel to redirect messages to a queue if the exchange fails. I'm using JConsole to monitor the number completed, but, it does not show the number failed. I understand the DLC handles the exception so I tried adding ".handled(false)" to my declaration but it doesn't

RuntimeCamelException during Sftp

2010-01-12 Thread ronP12
Hello, I have a SFTP route that takes a JMS message as input. In the message, there is a property that states where the local file is that needs to be transferred. I unmarshal the object and use the property (fileLocation) in the exchange In my code I do something like this: File transferFil

Change output file name in SFTP route

2009-11-04 Thread ronP12
Hello, I am using the SFTP component and I want to change the file name when it is placed on the remote server. Basically I would like it to behave like: from(file:/tmp/input.txt). to("sftp:/./directory/output.txt) I tried to manipulate the header using. setHeader("ou

Can error handling be added to a custom endpoint?

2009-10-29 Thread ronP12
Hi All, I was wondering if the ErrorHandler can be configured in an endpoint? For example, the SFTP component allows the user to configure certain fields (ie: privateKeyFile, knownHosts) when the route is created. Is there a way to add error handling properties such as maxRetries and deadLette