Re: How to programmatically reset an application property?

, reinit them and start again. It will take a time. Is it a thing > you really need? > > Any way you can put all needed properties in class fields to make them change. > ___ > Best wishes,Vyacheslav. > > Ron Cecchini 24 августа 2021 г. 07:53:29 написал: > > > I&#x

How to programmatically reset an application property?

I'm using Camel + Spring Boot. In my application.properties, I set a property 'foo.bar.size' In my routes, I use: {{foo.bar.size}} In some Java processor code, I use: camelContext.resolvePropertyPlaceholders("{{foo.bar.size}}") I now need to reset that property in some Java code and have it

Re: Is Camel's Kafka component auto-decompressing Snappy byte[] ?

e) throws Exception { MyObject obj = e.getIn().getBody(MyObject.class); [...] Anyway Thanks, Camel. It's all quite simple... once I know what I'm doing. > On 07/22/2021 8:07 PM Ron Cecchini wrote: > > > Hi, all. > > There is a non-Camel producer tha

Is Camel's Kafka component auto-decompressing Snappy byte[] ?

e is no way there should be any readable text whatsoever. So now I'm wondering, Is Camal:Kafka perhaps automatically doing *some* amount of decompression before I get to the .process()? I'm reading through the component doc but nothing is jumping out at me yet. (there's a lot there to process...) Thanks for any help. Ron

NoRouteToHostException - Address not available

for any tips. The error is pasted below. Thank you very much. Ron - [...] seda://call-service: Call to service failed. Exception: Cannot assign requested address (Address not available) seda://call-service: o.apache.http.impl.execchain.RetryExec: I/O exception (java.net.NoRouteToHo

Re: Spring based CamelContext Not Staring

ues. Again, thanks for your help! --Ron On Thu, Feb 4, 2021 at 2:09 AM Claus Ibsen wrote: > Hi > > If you use karaf then spring xml is via spring-dm which has been > deprecated, and its also not installed by default (I think anymore). > You may try to install camel-spring-dm featur

How would you parallelize this?

Hi, everyone. Say you have 2 vectors of integers, V1 and V2, of size M and N, resp. The core of the processing is to pair each element of V1 with each element V2 and call a web service with the 2 integers. So, M x N calls to a web service. I have routes that look like the following pseudo-Came

Spring based CamelContext Not Staring

ove file is sufficient to set up the context. Have there been significant changes from Camel 2.15 to 2.25 which would prevent this from working? Thanks, Ron

Looking for full stack project examples that use Camel

Hi everyone. I don't want to start off-topic threads here to ask general software architecture questions (even if they do involve Camel and Spring Boot). Instead, if I can look at some working examples on GitHub/GitLab, how the code is laid out, etc, that would be very useful. Feel free to em

Re: Asynchronously calling a route

hanks for any help figuring out where my brain cramp is... > On 08/28/2020 2:36 PM Ron Cecchini wrote: > > > Hi, guys. I've been following the "async" docs and examples and the few code > snippets I could find online, but I'm still having trouble doing som

Async and asyncCallbackRequestBody()

Hi, guys. I've been following the "async" docs and examples and the few code snippets I could find online, but I'm still having trouble doing something that I would think is very common. My use case is basically this: 1. I have a small route (call it "experiment") that hits an HTTP endpoint

Enabling global CORS support

Hi, guys. I have a Camel (3.4.2) + Spring Boot (2.3.1.RELEASE) web service using Undertow. I ran into my first CORS (cross-origin resource sharing) issue, googled around, and solved it with @CrossOrigin. My question has to do with why I could *not* solve it with restConfiguration().enableCOR

Custom splitter

Hi, all. Since the list is quiet I thought I'd run something by you. I wrote a custom splitter that's working just fine, so I really don't need any help. But I was curious if I could have done things simpler with some combination of split(), tokenize() and Simple, etc.? ~~~ I hit an endpoint

Re: custom component vs. sending to a route

POJO routing to hide some of Camel > https://camel.apache.org/manual/latest/pojo-producing.html > > > On Sun, Jun 21, 2020 at 11:41 PM Ron Cecchini wrote: > > > > Hi guys. I have to integrate a 3rd party’s message listener code into my > > routes. Their API is pretty

custom component vs. sending to a route

Hi guys. I have to integrate a 3rd party’s message listener code into my routes. Their API is pretty simple: listener(“foo”, fooHandler()); creates a listener using the underlying configured JMS and calls fooHandler() whenever it sees a “foo“ message. Instead of creating a full-blown Camel

Re: How to copy an exchange property to the global options?

/values as-is and not evaluated > during routing of an exchange as they are not intended for that. > > But if you want to do it anyway, then your process method can store > the body size as a value instead of a simple text. > > Something ala .put("xxx", exchange.getMess

Re: How to copy an exchange property to the global options?

p.s. While I'm at it, is there a way to *access* a GlobalOption from inside a route using Simple? > On May 1, 2020 at 12:24 AM Ron Cecchini wrote: > > > I'm trying to pass back the # of things I've processed in a route back to the > calling Java. > > Th

How to copy an exchange property to the global options?

I'm trying to pass back the # of things I've processed in a route back to the calling Java. This log() displays the correct number: .log(LoggingLevel.INFO, "Processing ${body.size} Things ...") I then tried putting that ${body.size} in a GlobalOption on the CamelContext so I can access it late

Re: (Spring Boot) Stuffing fat jars & run-time route startup

a new standalone tool from scratch. I was like, "If I can just get the user's params to *that* part of the pipeline, it will all work out nicely..." And now it does. Yay. Thank you, Spring & Camel. > On April 28, 2020 at 6:28 PM Ron Cecchini wrote: > > > Hi, ga

(Spring Boot) Stuffing fat jars & run-time route startup

Hi, gang. I hope you’re all doing well. Two questions if I could. TL;DR: (so you can decide now if you want to hit since this is long...) 1. How to add a resource file from a Maven parent to a child’s fat (Spring Boot) JAR? 2. How to parse command line args and have the main() call SpringAp

Re: Camel + Drill + Parquet

like Parquet. So migrating this Kafka->Mongo route to Kafka->Kudu is almost trivial. Anyway, time to bump up my Camel version to 3.0.1 and give Kudu a whirl... Thanks again. > On February 12, 2020 at 4:33 AM Omar Al-Safi wrote: > > > Hi Ron, > > By reading some intr

Camel + Drill + Parquet

seems to not find anything related to Camel and Parquet... Thank you so much! Ron

HTTP proxy problem

Hi, all. I have previously successfully used the HTTP component with proxy info to poll a site. Bu now I'm running into a "connection reset" problem when polling another site that has a slightly different connection strategy. The HTTP configuration for

Re: Need both camel-kafka-starter & camel-kafka in Spring Boot app?

"log.level()" to "if ( log.isLevelEnabled() ) log.level()" to prevent Java from allocating objects.) Anyway, thanks again. > On January 12, 2020 at 12:13 PM Jan Bednář wrote: > > > Hi Ron, > You are right, kafka-clients dependency was accidentally excluded in

Need both camel-kafka-starter & camel-kafka in Spring Boot app?

Does it make sense that I would need both camel-kafka-starter and camel-kafka in my Camel 3.0 / Spring Boot 2.2.1 app? I thought the *-starter would be enough, but without the camel-kafka dependency my Kafka consumer throws a: java.lang.NoClassDefFoundError: org/apache/kafka/clients/consumer/C

What is the default Log EIP log name?

TL;DR: I'm trying to use a single logger for both my routes (i.e. the Log EIP) and in my components. In my routes, I would like the displayed log name to be the Route ID, and in the components it should be the class name. Ok, it's about time I solved this one once and for all... I create my Ca

Re: Communicating a value between a route and the RouteBuilder class

> On December 12, 2019 at 11:16 AM Claus Ibsen wrote: > > You can also name your RouteBuilder class with a bean id, if you use > spring / spring-boot or cdi etc. And then refer to this bean ids, > where you can have methods that you can refer to in the simple bean > function. Then you dont need

Re: Communicating a value between a route and the RouteBuilder class

can use bean function in the simple language ${bean:xxx} to refer > to a bean by its id, then you can store your offset cache with some > bean id. > > On Thu, Dec 12, 2019 at 7:08 AM Ron Cecchini wrote: > > > > The use case is simply this: I need to poll and hit an HTTP e

Communicating a value between a route and the RouteBuilder class

The use case is simply this: I need to poll and hit an HTTP endpoint with an initial "offset" param of -1. The response header contains a new offset ("NEXT_OFFSET") to use the next time I hit the endpoint. Sounds simple enough... Until you start trying to do it... playing around with propertie

Re: Configuring Jackson for java.time

e"); context.getGlobalOptions().put("CamelJacksonTypeConverterToPojo", "true"); > On December 2, 2019 at 10:10 AM Zoran Regvart wrote: > > > Hi Ron, > for Jackson you need to add support for Java 8+ features explicitly. > > Have a look at how to do it her

Re: [ANNOUNCEMENT] Apache Camel 3.0.0 Released

java.io.InputStream with value [...] I finally hit on a temporary workaround - going back to using a java.util.Date instead of a java.time.OffsetDateTime - and it again all works great with Camel 3.0. But eventually I'll probably need to figure out how to use the newer Java date/times. Thanks fo

Re: [ANNOUNCEMENT] Apache Camel 3.0.0 Released

Christmas has come early! There's so much new stuff I'm not even sure what I should be excited about at the moment - but I'm excited! Thank you for all your efforts, guys! (and now I can spend pre-Thanksgiving feasting working through the Migration and eliminating the run-time crashes...) > O

Re: Camel and Swagger API *client* code

and .paralleProcessing(). I guess really the question is: if a route is receiving items one at a time, can you even do any kind of parallelization at that point; i.e. does the parallelization depend on being colocated with the split()? Ok, I'm asking the stupid questions I said I wouldn'

Re: Camel and Swagger API *client* code

pile time - which is perfectly suitable for my needs. And it's great that the plugin lets you specify either a URL or a local JSON file (which is what I'll end up using), and it lets you generate exactly the models you need (instead of all of them). I'm sure this is all old hat t

Camel and Swagger API *client* code

I'm taking a shot here... I'm new to Swagger. I see that Camel has integration for generating Swagger APIs. But what about *reading* someone else's API and using their schemas in my routes? I'm looking at Swagger Codegen to see how to generate the client code... But given Camel's infinite aw

Pipelining : Camel routes vs. Microservice architecture

Hey, guys. It's kinda quiet here so I thought I'd ask for some thoughts... I recently got put on a relatively small project that's nicely utilizing a microservices architecture. There are about 8-10 services and they're using Kafka. The whole thing is about 10k lines of Kotlin, and they do us

Re: One CamelContext vs. multiple CamelContexts

others approached this and what they found. (Mantas said his group put 400 routes in a single context!) Thanks again. Ron Sent from Xfinity Connect App -- Original Message -- From: Jan Bednář To: users@camel.apache.org Sent: September 28, 2019 at 12:42 PM Subject: Re: One CamelContext vs

One CamelContext vs. multiple CamelContexts

ve a cluster, and have to keep everything on a single beefy host, I guess the question is moot and you have to do as much as you can in one CamelContext until you hit a scalability limit... Thanks and have a good weekend. Ron

Spring configuring a bean

ext.xml" and "camelContext.xml" as well as putting the files under "resources" and "resources/spring". But none of those 4 configurations works. Thanks for any help. (I am now positioning my palm directly in front of my space so I can smack myself once my simple error is pointed out.) Ron

Re: How to unmarshal when you don't know what you're unmarshalling?

led out in this simple route if I use xpath(). (So that's 2 things that were nulling the body: xpath() and unmarshal().) At any rate, it works fine using "simple" and doing a string op. Maybe at some point I'll revisit trying to figure out what's going on with xpath()..

RE: How to unmarshal when you don't know what you're unmarshalling?

would be to inspect what's in the body in a processor > and setting a header or property of the type. Then you can use a choice to > basically route to the correct unmarshal code. You can use String find, or > regex if you want to do this and keep the body intact, then you can unmar

Re: How to unmarshal when you don't know what you're unmarshalling?

ll the way back to version 2.18.0, but that didn't solve my problem. Strange. I'm going to have to come up with some other trick to hang on to the body - so that I can reset the body - so that I can attempt the 2nd unmarshal. Wish me luck > On June 25, 2019 at 9:50 AM Mic

How to unmarshal when you don't know what you're unmarshalling?

Hey, all. I have a route that's sitting on a port and it can receive 1 of 2 different XML messages. I was simply going to try to unmarshal with the first one, and if it errors, unmarshal with the next one. But is there a smarter or best practices way to handle this? Thanks.

Re: Camel + Spring Boot as a backend?

. And if I had read past chapter 5, I would’ve seen that Claus already starts describing in chapter 7something like what I want... Thanks again. Ron -- Original Message -- From: Mark Nuttall To: users@camel.apache.org Sent: April 16, 2019 at 5:52 PM Subject: Re: Camel + Spring Boot as

Camel + Spring Boot as a backend?

simple Spring Boot + Camel + RDMS application, hosted on a beefy server and not running in an app server or Docker? Thanks. Ron

Re: AW: [DISCUSS] - Apache Camel 3 - A new tagline

(This is the graphic I was trying to send yesterday. Please excuse the horrendous ASCII "art" !) Infinite Integration! _ oo / ' |Java = Camel '_/ 1 > However with the new modern world of containers I came up with: > > * Apache Camel 3 - A full-stack integration framew

Re: [DISCUSS] - Apache Camel 3 - A new tagline

I'm not gonna lie, I don't like anything that comes after "integration framework" ... I still consider myself a newbie (to Camel), but I like Trilok Agarwal's idea to focus on what Camel is really known for (at least to this newbie) and does really well - simplifying integration. In fact, befo

Re: Camel & MongoDB guidance

d some choice() / when() / otherwise() -- and *bam*. Got it all done with very little code. Thank you, Camel. Ron

Camel & MongoDB guidance

Hi, guys. This isn't a burning emergency. I was just looking for some Camel-specific design guidance / feedback if anyone has any. I'm also really new to Mongo, so I have some questions about it that aren't specific to Camel. As usual, my actual question is relatively short, but I spend a lot

Re: Feedback on Deprecating the Camel Maven Archetypes

I don't know if you wanted comments here or on the ticket, but I'll just quickly say: I have made extensive use of the 'camel-archetype-spring-boot' and love it (and Camel) to pieces. > On November 28, 2018 at 12:21 PM Claus Ibsen wrote: > The Camel team is considering deprecating the Camel M

Re: Problem with netty4:udp and udpByteArrayCodec=true

formation about "caching" that made me think that maybe I shouldn't be doing the 'getContext().setStreamCashing(true)' I've been doing by default. So I commented that out - and it all finally worked just great. Thank you so much again! Ron FWIW, here's

Problem with netty4:udp and udpByteArrayCodec=true

lse I should try? I have never had any luck trying to install a non-default encoder/decoder, but in this case I don't think I even need it. I just need to serialize the protobuf to a byte array, and it seems that this 'udpByteArrayCodec' is exactly what I need. So how should I be using it? What could be preventing anything from appearing over the wire? Thank you so much as always! Ron

Timing problem of Spring Injection vs. Component Scan?

Hi, all. I have a Camel/Spring Boot app created from the camel-spring-boot archetype. I've set up my several Processor and RouteBuilder classes with @Component and have essentially avoided resources/spring/camel-context.xml. I'm now trying to incorporate a new class which has its own Spring co

Going from ‘camel-rabbitmq’ to custom messaging class

Hi, all. I’ve been successfully using the ‘camel-rabbitmq’ component and love it. However, I’ve unfortunately been tasked to replace it with an in-house custom class we’ve used on a number of projects to write/read to/from our RabbitMQ bus. To do this, do I need to create a new custom Connecti

Re: Help with Splitter/Aggregator-like behavior

really ended up being a thing of beauty... I'll include the sanitized code below for anyone who is interested. [ First I list the "before" SENDER / RECEIVER, which doesn't have data chunking, and then the "after" SENDER / RECEIVER which includes a "DataChunker&

Help with Splitter/Aggregator-like behavior

So, I have a situation where I need something like a Splitter and an Aggregator. But as far as I can tell from reading and googling, maybe my situation is nonstandard? >From what I can tell, a Splitter and Aggregator are used together within a >single route. In my case, I need the Splitter and A

Re: UDP: Netty4 vs. Mina2

is take me too long to figure out...) > On September 14, 2018 at 3:38 PM Ron Cecchini wrote: > > > Hi, Alex. Thank you you for your help. > > > I had read all of those pages (amongst the million or so I scanned...) > but your comment made it clearer as to what&#

Re: UDP: Netty4 vs. Mina2

e&sync=false") .log("*** AFTER write to UDP: ${body}"); } @Component("myBean") public class Encoder { public String foo (String val) { return val; } } } > On September 14, 2018 at 1:23 PM Alex Dettinger wrote: >

UDP: Netty4 vs. Mina2

I'll try a shorter version of my question: Why does this work: .to("mina2:udp://localhost:4?sync=false") ... from("mina2:udp://localhost:4?sync=false") and this doesn't work: .to("netty4:udp://localhost:4?sync=false") ... from("netty4:udp://localhost:4?sync=false") In

Problem with UDP (Netty4 vs. Mina2) & RabbitMQ (UDP vs. HTTP?)

Hi, there. I'm experiencing something weird here and I'm desperate for an answer. I realize this is a long message, but it's only because I'm verbose. It's a really straight forward setup, so I'm hoping it's just an obvious configuration issue... I have a simple Server and Client setup for s

Re: How to disable a servlet?

onfigure it to use a different port number than 8080. > > > On Mon, Aug 20, 2018 at 9:30 PM, Ron Cecchini wrote: > > Hi there. > > > > > > I am trying to run 2 Spring Boot / Camel applications at the same time, and > > the 2nd app complains about port 8080 alrea

How to disable a servlet?

mething other than 8080 -- and that worked, in the sense that I can now start up the 2 apps and write/read to/from the bus. But for my own education, I would *still * like to know how I can disable that 2nd servlet, esp. since it's not needed. Thank you very much. Ron

RabbitMQ: ConnectionFactory gives "Connection refused" yet I can write all in one .to()

Hi All. New Camel user here. I have a Spring Boot / Camel app and successfully got a route working which polls a REST endpoint, splits the JSON array into custom POJOS, transforms each one into one of our Protobufs, and then writes the protobuf out to our RabbitMQ. Great, right? Well, it

Re: MongoDB Jackson Date Mapping Option

Thanks so much for your help - For anyone else trying to solve this I'll show what I ended up doing that worked to map a Java date to a Bson date or ISODate in MongoDB. Created a custom serializer class: public class BsonDateSerializer extends JsonSerializer{ @Override public void serialize(Dat

Re: MongoDB Jackson Date Mapping Option

? thanks again, Ron -- View this message in context: http://camel.465427.n5.nabble.com/MongoDB-Jackson-Date-Mapping-Option-tp5727548p5727633.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: MongoDB Jackson Date Mapping Option

Hi Raul, Thanks for your helpful suggestion. I'm having an issue though that I can't seem to figure out and wondering if you have any ideas. Trying your suggestion I've set up the DataFormat as: ObjectMapper objectMapper = new ObjectMapper(); objectMapper.disable(SerializationConfig.Feature.WRIT

MongoDB Jackson Date Mapping Option

behavior using the following: objectMapper.configure(SerializationConfig.Feature.WRITE_DATES_AS_TIMESTAMPS, false); Is there a way to get access to the Jackson ObjectMapper to set this option during set up of the camel context etc? thanks, Ron -- View this message in context: http://camel

Re: PoolSize on from()

getDefaultThreadPoolProfile().setMaxPoolSize(30); > > Regards, > > /Daniel > > 2010/9/8 Ron Smith > > > I have my RouteBuilder doing this: > > > > from(tibco) > > .threads(readerThreads) > > .to("direct:localqueue"); > > from

PoolSize on from()

I have my RouteBuilder doing this: from(tibco) .threads(readerThreads) .to("direct:localqueue"); from("direct:localqueue") .threads(processThreads) .bean(MyParser.class, "parseMessage") .bean(MyPersistor.class, "persistRecord"); If I set processThread > 20, I get the following exc

Re: XPath Builder question

Note that it is not just XPath. Pretty much all of the XML parsers in the JDK are not thread safe. For instance, we were just having a related discussion here in another thread and, at the moment, I am using ThreadLocal to hold on instances of SAXParser for different threads. On Fri, Aug 13, 2010

Re: threads question

ing there isn't and I can kinda understand why because it is, in essence, creating a separate pipeline for each thread. Maybe that is the way to do it in camel -- create my route multiple times on the same endpoint. On Fri, Aug 13, 2010 at 1:53 AM, Claus Ibsen wrote: > On Fri, Aug 13,

Re: threads question

I don't really want a new bean every time it is called. I just want one for each thread. On Thu, Aug 12, 2010 at 1:22 PM, Claus Ibsen wrote: > On Thu, Aug 12, 2010 at 7:19 PM, Ron Smith wrote: > > I have created a route like this: > > > > from("tibco:que

threads question

I have created a route like this: from("tibco:queue:myqueue") .threads(10) .bean(StepOne.class, "handleMessage") .bean(StepTwo.class, "handleMessage") I had been testing my app without the threads(). After adding the threads() I was surprised to find that it still only creates one in

Re: latformTransactionManager not found in 2.4.0

s but, if someone (like myself) chooses (or is forced) not to use maven, then it is on their (my) head to resolve those dependencies. At least I have the definitive set of resources available to do the resolution. On Tue, Jul 20, 2010 at 10:03 AM, James Strachan wrote: > On 20 July 2010 14:21, Ron

Re: JMS Component WITHOUT Spring

value. I might actually take a stab at a non-spring jms component for camel because I am really liking the way camel works. On Tue, Jul 20, 2010 at 10:17 AM, James Strachan wrote: > On 19 July 2010 22:12, Ron Smith wrote: > > I'm with you, Jim. I think that is part of why others

Re: latformTransactionManager not found in 2.4.0

;> [INFO]org.springframework:spring-expression:jar:3.0.3.RELEASE:compile >> [INFO]org.springframework:spring-jms:jar:3.0.3.RELEASE:compile >> [INFO]org.springframework:spring-test:jar:3.0.3.RELEASE:test >> [INFO]org.springframework:spring-tx:jar:3.0.3.RELEASE:compile >> [INFO]org

Re: latformTransactionManager not found in 2.4.0

ses or jars). The last line of code throws: Exception in thread "main" java.lang.NoClassDefFoundError: org/springframework/transaction/PlatformTransactionManager at DemonstrateBug.main(DemonstrateBug.java:22) On Mon, Jul 19, 2010 at 10:20 PM, Ron Smith wrote: > I just

Re: latformTransactionManager not found in 2.4.0

y Spring 2.x jars. > > > Willem > -- > Apache Camel, Apache CXF committer > Open Source Integration http://www.fusesource.com > Blog http://willemjiang.blogspot.com > Tiwtter http://twitter.com/willemjiang > > Ron Smith wrote: > >>

Re: JMS Component WITHOUT Spring

I'm not griping, it just seems like everything in the java open-source world is starting to depend on everything else in the java open-source world. On Mon, Jul 19, 2010 at 3:57 PM, Jim Newsham wrote: > On 7/19/2010 8:13 AM, Claus Ibsen wrote: > >> Hi >> >>

latformTransactionManager not found in 2.4.0

After moving from camel 2.3.0 to 2.4.0 I am getting the error: java.lang.ClassNotFoundException: org.springframework.transaction.PlatformTransactionManager when I execute: context.addComponent("myjms", JmsComponent.jmsComponentAutoAcknowledge(topicConnectionFactory)); I am including every JAR i

Re: JMS Component WITHOUT Spring

Spring. James may be right -- it might be time to find a new job :-) On Mon, Jul 19, 2010 at 1:13 PM, Claus Ibsen wrote: > Hi > > > On Mon, Jul 19, 2010 at 8:06 PM, Ron Smith wrote: > > Where I work, Spring has been declared "evil" so I am attempting to use > &g

JMS Component WITHOUT Spring

Where I work, Spring has been declared "evil" so I am attempting to use camel without any of the Spring JARs but I can't find any examples of how to setup a JMS component without a Spring dependency. I am using Tibco as the JMS provider and it is providing JNDI. Here is a sample code snippet which