How to use component Flink in Karavan?

2023-08-28 Thread Xu Bill
Hello, I am trying to make a Camel integration in Karavan for communicating with Apache Flink. I have read the documents here (https://camel.apache.org/components/4.0.x/flink-component.html). There are some code sample for DataSet Callback and others. But I don't know how to do these things in

RE: How to use RoutePolicy to prevent a route from starting

2023-08-28 Thread Han Yainsun
Hi Jacek, Thanks for the advice! Yes this feature meet my needs. Sent from Mail for Windows 10 From: jacek szymanski Sent: 2023年8月28日 20:29 To: users@camel.apache.org Subject: Re:

Re: How to upload data to S3 as Multipart file while getting data in loopDoWhile EIP from Paginated API

2023-08-28 Thread Claudio Miranda
> I want to upload all this data received from all pages of paginated API to > be uploaded as single file in s3 (Multipart file). Camel S3 supports multipart upload to S3 https://camel.apache.org/components/3.21.x/aws2-s3-component.html#_s3_producer_operation_examples -- Claudio Miranda

Re: Camel 4.0 upgrade causes SEDA Hang

2023-08-28 Thread Tim Janusz
Thanks so much.. Give me a little time and I'll create a smaller app to demonstrate what we're seeing.. I'll reply once I have something available. On Mon, Aug 28, 2023 at 4:30 PM Otavio Rodolfo Piske wrote: > Hi, I'd like to investigate ... but for that I need a full reproducer. Can > you

Re: Camel 4.0 upgrade causes SEDA Hang

2023-08-28 Thread Otavio Rodolfo Piske
Hi, I'd like to investigate ... but for that I need a full reproducer. Can you provide* one, please? * Either as a test in the Camel Core code base or one that I can quickly clone and run. Thanks On Thu, Aug 24, 2023 at 6:54 PM Tim Janusz wrote: > Hi all, > > We're currently trying to upgrade

Registration open for Community Over Code North America

2023-08-28 Thread Rich Bowen
Hello! Registration is still open for the upcoming Community Over Code NA event in Halifax, NS! We invite you to register for the event https://communityovercode.org/registration/ Apache Committers, note that you have a special discounted rate for the conference at US$250. To take advantage of

Re: unable to work with streams + Artemis large messages with AMQP factory

2023-08-28 Thread Modanese, Riccardo
Sorry, I’m a bit confused! To be able to set minLargeMessage should I use *camel-jms*? There’s no other way, right? My implementation injects a factory into *camel-amqp* endpoint so I supposed to be able to change the connection driver without affecting *camel-amqp* functionalities. But from

Re: unable to work with streams + Artemis large messages with AMQP factory

2023-08-28 Thread Federico Mariani
I am afraid that in order to use minLargeMessageSize you need to use *camel-jms* component and *artemis-jms-client* as jms implementation, because camel-amqp uses *qpid-jms-client.*If you have some time, you can take a look to camel-jms

Re: unable to work with streams + Artemis large messages with AMQP factory

2023-08-28 Thread Modanese, Riccardo
Thanks for your reply, I'm going to investigate the links you provided. In the meanwhile, I can provide you few links to the code. The factory I originally used was (amqp???)

Re: How to use RoutePolicy to prevent a route from starting

2023-08-28 Thread jacek szymanski
Hi, wouldn't it be enough to disable auto startup on the backup route? https://camel.apache.org/manual/configuring-route-startup-ordering-and-autostartup.html js. On 28.08.2023 9:31, Han Yainsun wrote: Hi Camel Community, Greetings to you! Camel version: 3.20.4 Spring Boot version:

Re: unable to work with streams + Artemis large messages with AMQP factory

2023-08-28 Thread Federico Mariani
Hello, In camel-amqp component there are tests that uses Artemis amqp https://github.com/apache/camel/blob/main/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/artemis/AMQPEmbeddedBrokerTest.java#L44 and the connection is configured like this

unable to work with streams + Artemis large messages with AMQP factory

2023-08-28 Thread Modanese, Riccardo
Hello everyone, I’m working on supporting in a proper way the Artemis large messages through Camel streams. >From the documentation it looks like this is supported only using AMQP or CORE >protocol (no JMS). We use a custom factory since we need to set the connection client ID. I set up

Re: Global limit to threads count used by Camel (engine + routes pools + ..)

2023-08-28 Thread Modanese, Riccardo
Thank you for your reply. I’ll try asap From: Claus Ibsen Date: Monday, 28 August 2023 at 10:26 To: users@camel.apache.org Subject: Re: Global limit to threads count used by Camel (engine + routes pools + ..) Hi A thread pool profile is just a template for sharing the same settings, not the

Re: Global limit to threads count used by Camel (engine + routes pools + ..)

2023-08-28 Thread Claus Ibsen
Hi A thread pool profile is just a template for sharing the same settings, not the same pool instance. Instead use to create a pool instance and share this. See more in the docs https://camel.apache.org/manual/threading-model.html On Mon, Aug 28, 2023 at 9:53 AM Modanese, Riccardo wrote: >

Global limit to threads count used by Camel (engine + routes pools + ..)

2023-08-28 Thread Modanese, Riccardo
Hello to everyone, I’m working to place a cap to the threads used by my Camel routes. I have several routes (the number can vary time to time) and I created a thread pool profile like this one (Camel 3.x with SpringBoot 2.5.x) My routes have a recipient list and an error handler (no

How to use RoutePolicy to prevent a route from starting

2023-08-28 Thread Han Yainsun
Hi Camel Community, Greetings to you! Camel version: 3.20.4 Spring Boot version: 2.7.11 JDK: Amazon Corretto 17 Platform: Windows server 2019 IDE: IntelliJ IDEA 2021.3.2 (Community Edition) Stack Traces & logging output: attached at the end I have a case that two routes use the same HTTP