Re: SJMS transaction

Thank you for your answer. I use only one broker, so I don't need that kind of XA transaction as you pointed out. Anyway setting transacted=true on both consumer and producer does not solve the issue as there are always more than 1000 messages in input+output queue even there were 1000 messages in

Re: Redelivery per Endpoint

Yeah, but if you want a retry inside a retry, you hit a wall. I tried a lot of different configs with no success. I made camel-retry out of frustration. It took 3 hours to write it after loosing 2 days playing with error handlers. On Wed, Feb 10, 2016 at 2:19 PM, Claus Ibsen wrote: > Hi > > If

Re: OsgiServiceRegistry caching service references, why?

I think that should work fine. Are you willing to create a pull request for this? Christian On 11.02.2016 01:05, Richard Davidson wrote: No I plan to only proxy the service if it is available in the camel OsgiServiceRegistry and therefore not using blueprint. That way it can change in the bac

Why does every swagger paramet gets an (empty) enum

I switched from Apache camel 2.16.0 to 2.16.2 and now all my parameters get an additional empty enum even when no allowedValues are specified. Now Swagger UI displays an empty dropdown for all dataTypes. I do not think that is supposed to happen is it? Am I overseeing something?From camel-example-s

ActiveMQ Consuming

Hi folks, I have a short question : Is it possible to consume from 2 different brokers within a single Route with transactions. something like form("activemq1:queue1", "activemq2:queue" ) Do I need to specify a separate transaction manager pro ActiveMQConnectionFactory instance or is ther

Re: Camel Spring boots

use the following archetype while creating the project GroupId=org.apache.camel.archetypes Artifactid=camel-archetype-spring-boot version=2.16.1 This will create a Spring Boot Template to run the camel routes. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Spring-boo

UriParam multi value

Hi, I would like to know if there is way to have a multi value UriParam that accepts a comma delimited list of elements like: - definition: @UriParam private List options; - add thing to registry: registry.bind("option1", new MyOption("1")); registry.bind("option2", new MyOpti

Camel Spring Boot - Adding JmsComponent for WMQ to Camel Context

Hi, I am exploring Spring Boot to write the camel routes...I started off by creating a Maven Project using the camel-archetype-spring-boot. The project contained 2 classes, 1. a class that extends from fatjarrouter, which houses the camel routes 2. a class by name WarInitializer which extends Fat

Re: type save body() unboxing

Thanks for the answer. Honestly I am looking for a simple, "one line" solution instead of create a new Processor class or Bean or use inline Processor definition. -- View this message in context: http://camel.465427.n5.nabble.com/type-save-body-unboxing-tp5777342p5777594.html Sent from the Cam

Re: Camel Spring Boot - Adding JmsComponent for WMQ to Camel Context

You use a @Bean in spring boot to configure and setup the camel component. See for example https://github.com/apache/camel/tree/master/examples/camel-example-spring-boot-metrics Or you can use that CamelContextConfiguration callback and add the component in the before start method. On Thu, Feb 1

Re: Camel Spring Boot - Adding JmsComponent for WMQ to Camel Context

I found the answer I had to create a method that returned the jmscomponent and annotate it with @Bean. @Bean annotation is a synonym for the in camel-context.xml The name of the method is the bean name, which I used in my routes to communicate with the queues. listed as below, this will reg

Re: Camel Spring Boot - Adding JmsComponent for WMQ to Camel Context

thanks for the response.Posted my finding just before I saw your response. @Bean worked for me... Thanks, Ganga -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Spring-Boot-Adding-JmsComponent-for-WMQ-to-Camel-Context-tp5777593p5777597.html Sent from the Camel -

pass custom constant value to a bean in Spring XML

hello, I am trying to pass a constant value which is defined in a class, but it does not work .I am using 2.16.1 version of camel. I have defined as below in the XML. But the value of the Constant is not passed to the method and is always NULL. Is there anyway I can Re use the Constan

JRE Crash while Camel Import

Hi, i got a problem with my camel routes. I got a multi-threaded camel app with different routes and processors. I use Camel version 1.16.1 and Gradle. All works fine till the app crashes (after ~40min of runtime and great work) with the following error: -- # # A fatal error

Re: Multiple consumers for the same endpoint is not allowed cxfrs vs rest dsl

Thanks for the correct processor link. I'm summarizing main difference between rest dsl routes and cxfrs routes rest dsl can include the method .get .post .put .delete baked into the route This is an advantage if you want a different route for each http method, whereas the cxfrs has paths, params,

Re: Camel Spring Boot - Adding JmsComponent for WMQ to Camel Context

Hi Yeah in this case @Bean is like the CDI @Producs annotation. To create and produce a bean. There should also be a name or id attribute on @Bean you can use in case you want to set the bean name there instead of the method name. You may want to add @Bean for the connection factory so you can sp

Re: pass custom constant value to a bean in Spring XML

See the type function of simple at http://camel.apache.org/simple On Thu, Feb 11, 2016 at 3:01 PM, fxthomas wrote: > hello, > >I am trying to pass a constant value which is defined in a class, but it > does not work .I am using 2.16.1 version of camel. > I have defined as below in the XML. >

Re: Multiple consumers for the same endpoint is not allowed cxfrs vs rest dsl

The difference is declarative vs code-centric, in CXFRS we still have HTTP methods, but the custom processor needs to do the actual routing based on the matched verb. This verb is actually stored on the Camel exchange/message so I'd not be surprised if it were possible to do it declaratively w

Read file locations from table and copy to specific folder using pollEnrich()

I am trying to write a camel route that reads a database table to get the list of absolute file paths and then copy those files to another folder using pollEnrich(). But instead the pollEnrich() is copying the no of files which is equal to the no of rows returned by the sql and not according to the

multiple consumers from aws-sqs

I am using camel 2.14 and cannot upgrade to 2.15 for client reasons. I am experiencing an issue where if I have a message that errors out and is allowed to retry it locks up the queue. I understand that the default of the camel sqs component is to have 1 concurrent consumer. The spec says mul

Re: multiple consumers from aws-sqs

Sorry I misspoke. We are using camel 2.15 and this behavior is still happening. I just verified. Mary Cochran Red Hat Consulting Email: mcoch...@redhat.com | c: 419-543-0531 | http://www.redhat.com - Original Message - From: "Mary Cochran" To: users@camel.apache.org Sent: Thursday,

Re: Multiple consumers for the same endpoint is not allowed cxfrs vs rest dsl

If you're using the CXFRs with annotated interfaces there isn't a need to be aware of the verb that I'm aware of since the method invoked on the interface itself will actually determine the route to invoke when using the recipient list. The only qualifier there is that the Java interface method n

Re: Multiple consumers for the same endpoint is not allowed cxfrs vs rest dsl

On 11/02/16 16:23, Brad Johnson wrote: If you're using the CXFRs with annotated interfaces there isn't a need to be aware of the verb that I'm aware of since the method invoked on the interface itself will actually determine the route to invoke when using the recipient list. The only qualifier

Re: OsgiServiceRegistry caching service references, why?

I don’t know the guts of how all this works, but Tim’s question/comment concerns me a little because we use camel-scr currently and we haven’t seen any issues with dynamic service behavior that I know of. I’ve asked a colleague of mine to check and make sure, but I thought camel-scr was working

Re: ActiveMQ Consuming

You can always have two “from” clauses and route the exchange to a direct route for the common processing. from( “activemq1://queue1”).to( “direct://process ); from( “activemq2://queue2”).to( “direct://process ); from( “direct://process” )……. Can you give a little more detail on what you’re try

ActiveMQ Component and Connection Pooling not working

Camel Version: 2.16.0 ActiveMQ version: 5.13.0 Container/Environment: Karaf 4.0.4/Blueprint I tried the example for connection pooling here, using Blueprint and deploying to Karaf: http://camel.apache.org/activemq.html Here is my blueprint.xml. The RouteBuilder class just does a from("active

Re: Multiple consumers for the same endpoint is not allowed cxfrs vs rest dsl

In the future I may use the new REST DSL if I find an appropriate place for it. It seems rather straightforward. I'd just have to make sure I was working on an exclusive REST API and was certain that being tied to HTTP was going to be OK. I was a little surprised to find it embedded in the Route

cxf server basic authentication (using interceptor) does not protect wsdl browsing

Thanks to Chris Dail, we have been using his BasicAuthAuthorizationInterceptor to enforce basic authentication on a Camel CXF consumer endpoint (server), say, http://www.acme.com/test.svc. We noticed that the enforcement does not apply to the WSDL browsing (http://www.acme.com/test.svc?wsdl). Tha

ApacheCon NA 2016 - Important Dates!!!

Hello everyone! I hope this email finds you well.  I hope everyone is as excited about ApacheCon as I am! I'd like to remind you all of a couple of important dates, as well as ask for your assistance in spreading the word! Please use your social media platform(s) to get the word out! The more v

Method not found with new version of Camel when method @Overrides an interface method

I have the following code class MyClass extends Function{ @Override public String apply(Exchange exchange){...} } And in my route... setHeader(...).method("myInstance", "apply") In the previous version of camel I was using (2.12.3) this worked fine. However, I am switching to J

Memory Leak OnExceptionDefinition

LeakOfMemory.java A memory leak related to the fragment: onException (Exception.class) .handled (true) .to ("direct: routeError"); When creating routes 3000 and 3000 remove routes and take a memory dump, we still have the memo

Re: Memory Leak OnExceptionDefinition

DefaultManagementLifecycleStrategy class can not remove OnException Definition because it is not associated with any route. -- View this message in context: http://camel.465427.n5.nabble.com/Memory-Leak-OnExceptionDefinition-tp5777618p5777619.html Sent from the Camel - Users mailing list archiv

Re: SJMS transaction

It sounds like SJMS may be replaying a transaction. Either that or the producer and consumer are not using the same JMS Session. Since you’re not losing messages, I’d guess it’s one of those two scenarios. I’m not sure if JMS Session Transactions are guaranteed one and only once delivery - a

Re: Memory Leak OnExceptionDefinition

Even by setting the setRouteScoped property (true) leak memory still exists. -- View this message in context: http://camel.465427.n5.nabble.com/Memory-Leak-OnExceptionDefinition-tp5777618p5777621.html Sent from the Camel - Users mailing list archive at Nabble.com.

Which standard components / languages / options are known to be fast / slow?

Hello, My application has the requirement of processing 100s of messages per second per CPU. The absolute minimum is 200, and the more the better. Obviously, to do that, each message must take, on average, 5 milliseconds or less. Additionally, our Camel routes are fairly long and complex - message

Re: Which standard components / languages / options are known to be fast / slow?

I think it's unfair to test parallel processing with super light workloads like that. In my production application, we use parallel processing so we can make several SOAP or HTTP calls to various services. Of course setting up a threadpool to log messages is going to perform worse than the serial v

AWS Kinesis Support

Hey guys Just wanted to get a couple of points of clarification. I'm interested in using Camel + Kinesis. According to this page http://camel.apache.org/aws-kinesis.html it says that Kinesis was supported as of Camel 2.7. I doubt this to be true. In addition, I was wondering if there was any p

Re: Which standard components / languages / options are known to be fast / slow?

Are the stages all synchronous or can you inject asynchronous behavior? If you are able to use SEDA components instead of direct you can queue messages and associate thread pools/sizes with each of the stages to maximize performance of the processing of those parts that are the slowest. For examp

Re: Camel Spring Boot - Adding JmsComponent for WMQ to Camel Context

suream new to Spring annotations, will explore further... Thanks for the insight... Thanks, Ganga -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Spring-Boot-Adding-JmsComponent-for-WMQ-to-Camel-Context-tp5777593p5777627.html Sent from the Camel - Users mailing lis

Re: OsgiServiceRegistry caching service references, why?

Quinn, I will post something on Monday when back at work. However it shouldn't be hard to replicate if you uninstall the bundle providing the service and install a modified bundle offering the same service but with different functionality (e.g. perhaps just output something different to the consol

Re: AWS Kinesis Support

Yes its Camel 2.17 and not 2.7 ;) We love contributions so anyone is welcome to work on helping making the producer part. On Fri, Feb 12, 2016 at 12:41 AM, John D. Ament wrote: > Hey guys > > Just wanted to get a couple of points of clarification. I'm interested in > using Camel + Kinesis. Ac