Re: Camel AWS-DDB scan/query

Sorry was this ever resolved? I seem to be running into the same issue and as I dig into the stack I notice that at line 39 and 40 of the class org.apache.camel.component.aws.ddb.ScanCommand it seems to be over writing the previous Result headers with the input headers and the only result that sur

RE: How to call remote soap web service from a application using apache camel

hi Mathews, I have a requirement like, I need to create a sample Camel project which invokes the mock web service created in my local soap. I have the wsdl and created the mock in soap. I need to use the Spring DSL to make the web service call. I am beginner to use this Camel framework. Do you hav

multiple routes in single camelcontext with same reslut name

i want to understand how camel behaves if have multiple routes in single camelcontext with same "mock:wsResult" and "mock:wsError" for all routes and calling route from java using ProducerTemaplate and mcokEndpoint is it give me receptive thread result or error object in multiple environment or

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

Hi I have built camel and tested. The consumers are getting released. I am using it in a spring boot application. But after 5 requests Still I can see lot of threads getting created and not released. But in active MQ console no pending consumers. Please find below the screen shots 1) After Ser

Re: Memory management

If you force a GC after the activity dies-down, is the memory recovered? > On Apr 25, 2016, at 4:01 PM, Jeff Segal wrote: > > I've got a set of routes that make a bunch of web service calls in quick > succession, convert the XML to JSON and then save the results off to > MongoDB. This occurs on

Re: Example of JDBC idempotentRepository in Spring XML?

Never mind, I found it here https://access.redhat.com/documentation/en-US/Red_Hat_JBoss_Fuse/6.0/html/EIP_Component_Reference/files/_IDU_SQLComponent.html Anymore examples I will gladly accept. Thanks -- View this message in context: http://camel.465427.n5.nabble.com/Example-of-JDBC-idempoten

Memory management

I've got a set of routes that make a bunch of web service calls in quick succession, convert the XML to JSON and then save the results off to MongoDB. This occurs on a scheduled basis (using the scheduler component, configured to run every few hours typically). Functionally, it works great. But I'

Example of JDBC idempotentRepository in Spring XML?

I would like to track which files has been processed from FTP server in a MySQL Table. Thanks, -- View this message in context: http://camel.465427.n5.nabble.com/Example-of-JDBC-idempotentRepository-in-Spring-XML-tp5781683.html Sent from the Camel - Users mailing list archive at Nabble.com.

IdempotentRepository key removal within OnException

Hi, I have the below routes setup. The behaviour that I am noticing is that the key within the Idempotent Repository is not being removed when an exception is thrown when using the 'seda' component in the OnException (on line stated below). If I change to use 'direct' instead of 'seda' within

LevelDB component losing 1 message everytime when jar restarts

Hello all, We are using levelDB for aggregation persistence. We are having an issue where one message is lost every time we stop the Camel job and restart. Ie say we have submitted 5 messages, and we stop the jar, and start again, one message(a random one ie not always first , last etc), is ge

Re: Not seeing query params on REST DSL

That is for the api documentation. Its the camel-restlet component that does the actual mapping from restlet to camel exchange/message. On Mon, Apr 25, 2016 at 7:59 PM, Steve Huston wrote: > Ok, what registers the query param if this doesn't? > > restConfiguration().component("restlet").port(900

RE: Not seeing query params on REST DSL

Ok, what registers the query param if this doesn't? restConfiguration().component("restlet").port(9000); rest("/asset") .put("/{addr}/pong").param().name("id").type(RestParamType.query).endParam() .to("log:steve?showAll=tru

Re: Not seeing query params on REST DSL

Apologies as I missed this. As far as I know, you need to explicitly register your query params. They are not automatically propagated. John On Mon, Apr 25, 2016 at 1:33 PM Steve Huston wrote: > On the risk of aggravating people (sorry) popping this up to today's > content... any help is most

RE: Not seeing query params on REST DSL

On the risk of aggravating people (sorry) popping this up to today's content... any help is most welcome. Thanks! -Steve > -Original Message- > From: Steve Huston > Sent: Wednesday, April 20, 2016 8:57 PM > To: users@camel.apache.org > Subject: Re: Not seeing query params on REST DSL >

Re: MQTT connectAttemptsMax property does not appear to work

This ticket would be a bit related to this, so route starting can be done in the background https://issues.apache.org/jira/browse/CAMEL-9465? On Mon, Apr 25, 2016 at 11:43 AM, whulse wrote: > We have created a simple route from activeMQ to RabbitMQ using MQTT however > when camel starts up and th

Default binding mode for REST

I'm not sure if this is a bug or typo or what :-) I have a simple rest DSL configuration: restConfiguration() .component("jetty") .port(9097) .bindingMode(RestBindingMode.auto); If I take out the binding mode, everything is interpretted as

Re: Camel is unable to use concurrent consumers for polling pending messages just after the start

Thanks for the quick response!! Can you share something about the algorithm how camel works in order to poll and process? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-is-unable-to-use-concurrent-consumers-for-polling-pending-messages-just-after-the-start-tp5781666

Re: Camel is unable to use concurrent consumers for polling pending messages just after the start

See this FAQ at ActiveMQ http://activemq.apache.org/i-do-not-receive-messages-in-my-second-consumer.html And about the prefetch buffer of ActiveMQ On Mon, Apr 25, 2016 at 6:30 PM, sabyasachi087 wrote: > I have a scenario where I have multiple queues to poll, which then throttles > the message in

Re: Camel Swagger and Cors in StandaloneMode

Hi Yeah you need to enable cors in restConfiguration and due to a bug in 2.17.0, you need to set the cors=true as a apiProperty as well. See here for an example https://github.com/camelinaction/camelinaction2/blob/master/chapter10/swagger-ui/src/main/resources/camel.xml#L47 On Mon, Apr 25, 2016

Camel is unable to use concurrent consumers for polling pending messages just after the start

I have a scenario where I have multiple queues to poll, which then throttles the message into a processor (to bean). I have configured concurrent consumers in jmsConfig and comma separated queues in "from" method or tag. During initial startup, all the pending messages in the queues are being pic

Re: java.lang.IllegalArgumentException: Cannot add component as its already previously added: jms

Hi Antonin and Claus, Yes, that did the trick, many thanks. Kind regards, Nicolas -- View this message in context: http://camel.465427.n5.nabble.com/java-lang-IllegalArgumentException-Cannot-add-component-as-its-already-previously-added-jms-tp5781607p5781665.html Sent from the Camel - Users

Camel Swagger and Cors in StandaloneMode

Hello all, i want to use swagger to document my rest api which run in camel 2.17.0 as standalone application. This seems to work fine. Unfortunately its not possible to test the api via the swagger ui. On http://camel.apache.org/swagger-java.html i found the information that i should set up and co

Context component with response reply protocol:how to handle timeout in onCompletion with exception?

Hi, I am trying to implement a protocol (called ATS-M), which splits messages for transportation and aggregates on receiving. When the receiver gets correct segments, it returns response messages. The sender waits for these response messages. So it works asynchronously cause the sender cannot w

Re: java.lang.IllegalArgumentException: Cannot add component as its already previously added: jms

> On 25 Apr 2016, at 15:20, Claus Ibsen wrote: > > On Mon, Apr 25, 2016 at 3:15 PM, Antonin Stefanutti > wrote: >> Hi Nicolas, >> >> There is some sort of cyclic dependency in your code from the CDI standpoint. >> >> You have an injection point for @Uri("jms:...") while your have the producer

Re: java.lang.IllegalArgumentException: Cannot add component as its already previously added: jms

On Mon, Apr 25, 2016 at 3:15 PM, Antonin Stefanutti wrote: > Hi Nicolas, > > There is some sort of cyclic dependency in your code from the CDI standpoint. > > You have an injection point for @Uri("jms:...") while your have the producer > method for the component in the same bean. > > I would sugg

Re: java.lang.IllegalArgumentException: Cannot add component as its already previously added: jms

Hi Nicolas, There is some sort of cyclic dependency in your code from the CDI standpoint. You have an injection point for @Uri("jms:...") while your have the producer method for the component in the same bean. I would suggest you either move the producer method in a separate bean, like JmsComp

Re: Camel not being able to start up if the RabbitMQ server using MQTT or STOMP is unavailable

it would seem that some of the MQTT properties do not work as expected such as connectAttemptsMax as it only tries to connect once then fails.. Has anyone else observed this and has a workaround/fix ? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-not-being-able-to-s

Re: java.lang.IllegalArgumentException: Cannot add component as its already previously added: jms

Hi Claus, Many thanks for your suggestion. Now the code looks as follows: public class MyRoutes extends RouteBuilder { @Inject @Uri("file:data/inbox?noop=true") private Endpoint inputEndpoint; @Inject @Uri("jms:incommingData") private Endpoint resultEndpoint; @Produces @Named(

Camel testing with embedded dependencies in bundle

Hi, I’ve got a Camel project which is to be deployed into servicemix as an OSGi-bundle where I’ve embedded a couple of third-party jars in the bundle. This works nicely. However, the class path to these bundles is set in MANIFEST.MF which is not generated until *after* tests are run if I do a

MQTT connectAttemptsMax property does not appear to work

We have created a simple route from activeMQ to RabbitMQ using MQTT however when camel starts up and the RabbitMQ broker is down, camel and activeMQ shut down. We have set the mqtt property connectAttemptsMax=-1 which should just retry the connection, but this does not seem to work. The following

Re: java.lang.IllegalArgumentException: Cannot add component as its already previously added: jms

Maybe use CDI @Produces to setup that component and with @Named you can assign the name @Produces @Named("jms") public Component jmsComponent() { ... } On Sat, Apr 23, 2016 at 1:54 PM, nicolasduminil wrote: > Hello, > > I'm trying to run a simple route copying a file content to a JMS destinat

Re: java.lang.IllegalArgumentException: Cannot add component as its already previously added: jms

Hello, Many thanks for your reply. Unfortunatelly, doing the mentioned modification doesn't change anything to the described behaviour. Kind regards, Nicolas DUMINIL -- View this message in context: http://camel.465427.n5.nabble.com/java-lang-IllegalArgumentException-Cannot-add-component-as-

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

You need to build camel-core as 2.17.1 SNAPSHOT also. You can look at the release history of Camel to have an idea when new releases are coming out. But I would expect 2.17.1 released in next month. On Mon, Apr 25, 2016 at 10:17 AM, arunkabraham wrote: > I built the camel-rx module and used the

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

I built the camel-rx module and used the latest jar in my code. Now I am getting an error Exception in thread "main" java.lang.NoSuchMethodError: org.apache.camel.CamelContext.addService(Ljava/lang/Object;ZZ)V at org.apache.camel.rx.support.EndpointSubscription.(EndpointSubscription.java:

Retriving data from json and inserting to the tables

Hi, I have route where in i process some data, I want this processed data to be used as input to the uri which will insert to the table. rom("timer://Timer?period=55000") .setBody(constant(metaDataBuff.toString())) .to("jdbc:myDataSource") .process(new Proces