RE: throttling/backpressure on a route

Hi Peter, Yes, it's running on a different machine that's dedicated to RabbitMQ and we are serializing the messages to disk - exchange.getIn().setHeader("rabbitmq.DELIVERY_MODE", 2), though I'm not sure if that header is actually needed for the broker to manage its own memory usage (we set it

Re: [HEADS UP] Camel K is here!

Awesome and very well done, kudos! Babak > On 17 Oct 2018, at 00:24, Nicola Ferraro wrote: > > Hi folks, > after some months of brainstorming with the community and a bit more than > one month of development, our Camel K project has reached a good level of > stability and I've published the

RE: throttling/backpressure on a route

Hi Peter, Could you potentially use a message broker (RabbitMQ, ActiveMQ etc.) downstream from the aggregator that is causing you concern? Mongo -> Aggregator -> Message Broker Queue -> Consumer -> ... -> Mongo With the consumer counts it's quite easy to restrict throughput to the max your

Re: Established Java DSL route into Camel Spring OSGi container - for use with Kataf container

Thanks Quinn for your advice and patience (and for the rest of the forum members!) I did attempt to make the changes below.. and to research the elements you presented to understand them better.. However, I'm still at an impasse. I still cannot "deploy" into Karaf.. Perhaps this is a Karaf

Re: throttling/backpressure on a route

Hi Valdis, and your MQ is throttling how? Serializing it to disk? Or is it keeping it in RAM but running on a different machine? It seems to be a bit of an overkill :) I just found ThrottlingInflightRoutePolicy, reading its description it seems to be what I'm looking for. I will double-check

Re: [HEADS UP] Camel K is here!

Yeah, it's great to see we can use Camel more easily with K8S. It's awesome that camel-k can be a part of Camel 3 :) Regards, Willem Jiang Twitter: willemjiang Weibo: 姜宁willem On Wed, Oct 17, 2018 at 6:24 AM Nicola Ferraro wrote: > > Hi folks, > after some months of brainstorming with the

AW: invoke mock after convertBodyTo

Hi there, in the meantime I found the reason for the error: my converter had thrown an exception, and that did not show up. Kind regards, Christian Jacob Von: Jacob, Christian Gesendet: Mittwoch, 17. Oktober 2018 10:04 An: users@camel.apache.org Betreff: invoke mock after convertBodyTo Hi

invoke mock after convertBodyTo

Hi there, I have a problem with invoking a mock after using a custom converter. In my test class, I've injected the MockEndpoint this way: @EndpointInject(uri = "mock:simpleMeasureConverted") private MockEndpoint mockSimpleMeasureConverted; and in my route, it is invoked this way:

Re: [HEADS UP] Camel K is here!

Hi Yay this is really great and its awesome to see Apache Camel becoming even more awesome on containers. And when we get the ball rolling even more on Camel 3 then combined its gonna be fantastic for Camel and its community. And even James Strachan must be proud, with Camel K on Kubernetes and

Consumers stop working after some time

Hi, I'm using activemq(5.14.5) with camel(2.13.4) because I still need java 6. I have a queue and 15 consumers. The messages sent to them are request reply. When I start the consumers, the messages are distributed one per consumer as soon as the messages arrive but, after some time, only one

Re: throttling/backpressure on a route

Hi Onder, Onder SEZGIN writes: > Hi, > I would suggest > 1- Take a look at throttle-eip. (Make sure you understand split, aggregate > and mongodb3 producer adocs around mongodb aggregation. Try and see your > case unless you can explain or create a unit test to pinpoint your issue > and also

Re: [HEADS UP] Camel K is here!

I love it. Great to see Camel truly delivering on its "integrate everything" mission. - Ashwin... Ashwin Karpe Apache Camel Committer & Enterprise Integration Practice Lead, North America Red Hat http://www.redhat.com Mobile: