Re: Netty Http4 (client): Null body whereas content-length > 0

Hello, I do manage to solve my problem. It has to do with jar packaging (with unpack dependencies option on). I figure it out because the test was OK in Eclipse but not in Windows Console. After having created jar with dependencies in subfolder, everything works smoothly (and very fast: before it

Splitter and Aggregator

Can we use together with Splitter & Aggregator as below If no, can I know why. Thanks -- View this message in context: http://camel.465427.n5.nabble.com/Splitter-and-Aggregator-tp5793551.html Sent from the Camel - Users mailing list archive at Nabble.com.

Camel Cache - Trigger an event when the cache expires

Hi, I have a scenario where in I need to perform a set of operations when the cache expires (based on the timetolive set). As part of this operation, the cache will be populated with the new value. >From the documentation, I could not find anything specific. Is this possible and if yes, any guida

Apache Camel aggregate route with exception

I want to use Apache Camel parallel multicast to 3 routes and aggregate (and wait for) 2 of them while leave 3rd go on its own (3rd one should not block first two). I also need to process these two in "all" cases meaning that if one of them fails (e.g. throws an exception during processing), it sho

Camel filter didn't work

Hi, I am trying to transfer file through sftp config. But don't know why camel filter not working. I am using camel 2.17.3 and jdk 1.7 I don't know how to solve it. If you have any kind of thoughts please share.Thanks in advance In my applicationcontext.xml

Re: Camel filter didn't work

It looks more of a spring issue than a camel one: CannotLoadBeanClassException: Cannot find class [in.client.camelbean.MyFileFilter] for bean with name 'myFilter' Make sure you don't have a typo in your spring xml file 2017-02-07 18:10 GMT+01:00 shubho : > Hi, > I am trying to transfer file t

SFTP get - chaining routes

Hi all, I'l trying to configure sftp get of a payload file from a remote server if a trigger file exists. E.g. if on the remote server: file1.done file1 if a trigger file "file1.done" exists then get both the trigger file and payload file. This way the remote machine guarantees that the payload

aggregation completion timeout == 0 problem

Camel version 2.18.1. I've got an aggregation route that consumes from a JMS queue. from(createFromUri()) .routeId(RouteId.NOTIFICATION_AGGREGATOR.getId()) .aggregate(header(JmsProperty.JMSXGroupID.getPropertyName()), aggregationStrategy)

Re: aggregation completion timeout == 0 problem

Set the timeout to a default value and then you can use that header to override if it has a value or not. See the table in the doc: http://camel.apache.org/aggregator2 On Tue, Feb 7, 2017 at 9:24 PM, Shults, Benji wrote: > Camel version 2.18.1. > > I've got an aggregation route that consumes fr

Re: SFTP get - chaining routes

See the content enricher EIP and the pollEnrich On Tue, Feb 7, 2017 at 8:38 PM, Gabriel Kapitany wrote: > Hi all, > > I'l trying to configure sftp get of a payload file from a remote server if a > trigger file exists. E.g. if on the remote server: > file1.done > file1 > > if a trigger file "file1

Re: Camel Cache - Trigger an event when the cache expires

Try to research the jcache api what it offers in this regard. Not sure if the camel-cache has anything for callbacks on expiry, but maybe there is some interface you can implement and hook into it. In other words dive into the code yourself and research the jcache api. And you are welcome to sha

Re: Splitter and Aggregator

Ask the computer, build a Camel route and give it a try On Tue, Feb 7, 2017 at 11:20 AM, Demon Hunter wrote: > Can we use together with Splitter & Aggregator as below > > > > > > If no, can I know why. > > Thanks > > > > > -- > View this message in context: > http://camel.465427.n5.nabble.co

RE: aggregation completion timeout == 0 problem

I am setting it. But when I set it to 0L, the aggregation does not complete. The second (and worse) problem is that when I set the timeout header to a value greater than 0L, the processor gets called but exchange.getIn().getHeader(Exchange.AGGREGATED_COMPLETED_BY, String.class); returns null.

RE: aggregation completion timeout == 0 problem

I think I've figured these things out. Apparently timeout must be > 0 to take effect. (Is this documented?) Also, Exchange.AGGREGATED_COMPLETED_BY is a property and not a header. -Original Message- From: Shults, Benji [mailto:benji.shu...@windlogics.com] Sent: Tuesday, February 07, 2

Using Camel to quickly execute just one route?

Hello I'd like to integrate Apache Camel into an existing project and just use some of it's endpoint capabilities (ftp, file, sftp etc.) to fetch some files and maybe validate them a bit. I don't want Camel to act as the main controller that dispatches everything in the background. Is it possibl

Re: Splitter and Aggregator

sorry I'm reading splitter and aggregator EIP. I don't see the examples which are using together with splitter and aggregator. However, I see there's one EIP call composed process which helps using splitter to be using together with aggregation by adding aggregation strategy as option on split tag.

Kafka Producer Serialization Error

I am new to camel and kafka. I am using Camel 2.18.2 with Kafka 0.10.1.1 I am getting this error and don't understand why: org.apache.kafka.common.errors.SerializationException: Can't convert value of class [B to class org.apache.kafka.common.serialization.StringSerializer specified in value.seria