Re: Passing a file through camel route

2016-11-29 Thread Siddharth Patil
I was able to solve the problem. I made a mistake while specifying the path. In the client endpoint I specified the address as : *"http://itlcpu703:8080/RestUploadFile/rest/file/upload"* and in the client end point (java class) also I specified @path annotation as : *@path("/upload")* *So

Re: dynamic endpoint with dynamic encoding

2016-11-29 Thread Claus Ibsen
On Tue, Nov 29, 2016 at 8:03 PM, Steve973 wrote: > Oh, change the parentheses for your header expression to curly braces. > Yeah well spotted. The charset option ought to work on the producer side also. > On Nov 29, 2016 10:36 AM, "morten"

AW: How to use the InOut (Request-Reply) pattern in combination with REST/Jetty?

2016-11-29 Thread Wein, Frank (RRZE)
Hi Claus, unfortunately this still results in a the same error message (The OUT message was not received...). Route now looks like this, rest of the code stayed the same: rest("/API/") .get("/object/{ID}/") .to("direct:objectGet");

Re: dynamic endpoint with dynamic encoding

2016-11-29 Thread Steve973
Have you tried using simple? On Nov 29, 2016 10:36 AM, "morten" wrote: > I am hoping to pass the encoding dynamically to a file component. > Basically I > need to store an error record in a file with the same encoding as the > inputfile (encoding is changed during

Aggregate multiple messages into a single output stream

2016-11-29 Thread Jan Bernhardt
Hi Camel users, is it possible to aggregate multiple messages (body from an exchange) into a single output stream? I would like to use the seda component (single threaded) to collect multiple messages, then each message (String body) would be sent to an aggregator. The aggregator should write

camel-kafka 2.18.0 KafkaConsumer manual commit

2016-11-29 Thread smalisi
Hi, i have a camel route consuming from kafka. When an unhandled Exception is thrown within that route i do not want the kafka offset to be committed. As a first step i set the autoCommitEnable property to false. This is my route: public static final String START_KAFKA_RECEIVER =

Re: dynamic endpoint with dynamic encoding

2016-11-29 Thread Steve973
Oh, change the parentheses for your header expression to curly braces. On Nov 29, 2016 10:36 AM, "morten" wrote: > I am hoping to pass the encoding dynamically to a file component. > Basically I > need to store an error record in a file with the same encoding as

dynamic endpoint with dynamic encoding

2016-11-29 Thread morten
I am hoping to pass the encoding dynamically to a file component. Basically I need to store an error record in a file with the same encoding as the inputfile (encoding is changed during processing). The original encoding is stored in a header called inputFileEncoding here what i have tried: 1)

AW: How to use the InOut (Request-Reply) pattern in combination with REST/Jetty?

2016-11-29 Thread Wein, Frank (RRZE)
Hi, thanks for the link, unfortunately it still doesn't seem to work. The Exchange does not receive a reply message: "org.apache.camel.ExchangeTimedOutException: The OUT message was not received within: 2 millis due reply message with correlationID: [...]-33309-1480438574020-0-3 not

Re: How to use the InOut (Request-Reply) pattern in combination with REST/Jetty?

2016-11-29 Thread Claus Ibsen
Ah you need to break this up into two separate routes from direct foo to activemq test from activemq test process replyProcessor On Tue, Nov 29, 2016 at 6:21 PM, Wein, Frank (RRZE) wrote: > Hi, > thanks for the link, unfortunately it still doesn't seem to work. The