Re: Using cxfrs producer with a dynamic endpoint from a metadata file

Thanks Yogesh for the pointer to recipientList EIP. This worked. The property uri that I was storing on the exchange earlier is now used directly in the recipientList method as: .recipientList(exchangeProperty(uri)) I'm still using the intermediary processor though to set the Authorization

Re: Stop a SQL route in Apache Camel

Hi You need to think more about your design. If the data is kept in the table you need to consider using idempotent consumer to filter out old data. Or you can update the data in the table either by updating a row by marking it as seen or delete it etc. Or alternative you can use a timer /

Re: Pojo @Consumer Annotation

Hi, i simplify my select to guarantee a result and remove all sql options : @Consume(uri = sql: select codaz, codbus, logmsg from bus.buslogger where loglev = 'STS_CFG'?dataSource=#dataSource.nagios) public void process(Object body) { System.out.println(wait); } but parameter

Re: Using cxfrs producer with a dynamic endpoint from a metadata file

Hello Praneeth, Yes certainly, Groovy or Beanshell could be of helpful. Regards, -Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/Using-cxfrs-producer-with-a-dynamic-endpoint-from-a-metadata-file-tp5768224p5768253.html Sent from the Camel - Users mailing list

Stop a SQL route in Apache Camel

I'm currently trying to import some data from Oracle to ElasticSearch (in JSON format) using Apache Camel. I'm totally new on this framework, so I was thinking that you might help with it ! Here is my code : from(sql://select log_instance_id, calculated_status, begin_date, end_date,

Re: Pojo @Consumer Annotation

Hi What version of Camel do you use? And have you tried with latest release? On Mon, Jun 15, 2015 at 11:37 AM, kalber karlheinz.al...@swslt.com wrote: Hi, i simplify my select to guarantee a result and remove all sql options : @Consume(uri = sql: select codaz, codbus, logmsg from

Re: SFTP Buffer size

There are no such parameters available to use directly. If you want to get it worked ,you need to change the code in deployed jar. It worked for me. -- View this message in context: http://camel.465427.n5.nabble.com/SFTP-Buffer-size-tp4630719p5768260.html Sent from the Camel - Users mailing

Re: Camel CXFRS and WADL generation

Hi This is probably more of a CXF question, you can directly configure org.apache.cxf.jaxrs.model.wadl.WADLGenerator, set it as a bean inside cxf:rsServer/cxf:providers, and configure it with the publishedEndpoitUrl property, HTH, Sergey On 13/06/15 01:27, Goodwin, Matthew wrote: I am

Re: DeadLetterQueue -- Access the object before shutDown

Hi You can access the inflight repository, it has a list of all the exchanges that are inflight. But afair we dont have a public api that allows end users access to the pending exchanges on the DLC. We may want to expose some api on the management layer in ManagedErrorHandlerMBean, so end users

Re: Pojo @Consumer Annotation

15-06-2015 13:31:24 INFO [main] MainSupport: Apache Camel 2.15.2 starting - kh -- View this message in context: http://camel.465427.n5.nabble.com/Pojo-Consumer-Annotation-tp5768168p5768259.html Sent from the Camel - Users mailing list archive at Nabble.com.

Splitter aggregation, memory and performances issue

Hi, I encounter a severe memory peak and progressive performances degradation problem while processing a split. Here is a simplified schema of the route: from(direct:fire) [.. stuff done here..] .split().method(dataFilesSplitter, splitByPeriod) .unmarshal(new

Re: Using cxfrs producer with a dynamic endpoint from a metadata file

Thanks again for the pointer Yogesh. Groovy worked but it's a little messy :) I used this in my route: .setHeader(Authorization).groovy('Basic ' + (exchange.properties.username + ':' + exchange.properties.password).bytes.encodeBase64().toString()) -- View this message in context:

s3 query

Hi, my use case is a dynamic consumer where , .setHeader(S3Constants.KEY, simple(query + System.nanoTime())) - this should change according to time .to(aws-s3://camel-qq?accessKey=secretKey=); can anyone help me Thanks

Re: Remove breadcrumbId from Rest Service Response Headers

Hello: I guess it must be the way I am writing my integration test. When manually testing the service with curl, the header is not preset, as expected. When I try to verify it in an integration test, the header is present: ProducerTemplate testProducer =

Re: Stop a SQL route in Apache Camel

You would need to do some message translation from the resultset of SQL to whatever json format ES requires to use. On Mon, Jun 15, 2015 at 2:05 PM, alexis.jacquemart aceso...@hotmail.fr wrote: Thanks for you answer, I can't add data in the table, we have a scheduler with the last key added

Re: using TransactionErrorHandler with Camel and Karaf

Thanks Claus! Regards, -Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/using-TransactionErrorHandler-with-Camel-and-Karaf-tp5768124p5768267.html Sent from the Camel - Users mailing list archive at Nabble.com.

RE: Camel CXFRS and WADL generation

Ok. Thanks. I will go that approach. Matt -Original Message- From: Sergey Beryozkin [mailto:sberyoz...@gmail.com] Sent: Monday, June 15, 2015 5:44 AM To: users@camel.apache.org Subject: Re: Camel CXFRS and WADL generation Hi This is probably more of a CXF question, you can directly

Re: Stop a SQL route in Apache Camel

I think I miss something. How the timer could change the result of the query ? The SQL query is supposed to return me a List of HashMap with all the couples from the database, how the timer can change this list ? -- View this message in context:

Re: HttpProducer to ignore response body avoiding stream caching

Should I take care of opening a JIRA issue to request the feature? Thanks -- View this message in context: http://camel.465427.n5.nabble.com/HttpProducer-to-ignore-response-body-avoiding-stream-caching-tp5767260p5768274.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Stop a SQL route in Apache Camel

Thanks for you answer, I can't add data in the table, we have a scheduler with the last key added in the database and we will do our updates at specific dates with this key. This part is for later ;) The problem is that when I try to use a simple timer like

Re: HttpProducer to ignore response body avoiding stream caching

Hi, yes, if you want, or I can open a JIRA issue for you. You can also submit a patch or a PR to resolve the issue :-) Bye Andrea Cosentino -- Apache Camel Committer Email: ancosen1...@yahoo.com Twitter: @oscerd2 Github: oscerd On Monday, June 15, 2015

Re: Camel quartz memory leak

I am using camel 2.15.1. Stopping the route using JMX, againg restarting it using JMX. Also the same getting same error if I restart entire camel context. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-quartz-memory-leak-tp5768063p5768275.html Sent from the Camel -

Re: HttpProducer to ignore response body avoiding stream caching

Hi Yeah sure a JIRA is welcome. Though we should take care to not always add new functionality from a single request in the community to avoid bloat the components with a zillion options. On Mon, Jun 15, 2015 at 4:08 PM, Marco Crivellaro marco.cr...@gmail.com wrote: Should I take care of

Re: Remove breadcrumbId from Rest Service Response Headers

Current camel-http component just copy the in message header to the out message header, so it can explain that why you get the Exchange.BREADCRUMB_ID from the out message. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English)

Re: Camel quartz memory leak

When you stop the route, the schedule won’t be shutdown. But if you stop the camel context, the schedule will be shutdown if there is no CamelJob there. Are there more than one camel-quartz endpoints in your camel route? -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog:

Re: s3 query

I’m not quit sure about the meaning of dynamic consumer. You can setup the CamelAwsS3Key header to the S3Producer, but you cannot setup the header in the S3Consumer side. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English)

Re: HttpProducer to ignore response body avoiding stream caching

I just create a JIRA[1] for it. [1]https://issues.apache.org/jira/browse/CAMEL-8876 -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On June 16, 2015 at 12:04:07

Validate DSL and message returned to client

Hi, In my Rest DSL route, I use the Validate DSL and mvel to validate data as it goes through the pipeline. If there's a validation exception, I would like to return back to the client both an HTTP_RESPONSE_CODE 400 as well as the reason for the error in the body. I'm able to set the HTTP

Re: using basic auth to protect camel rest dsl routes

This is useful, but can we do rest dsl route level authentication with embedded jetty? I was only able to do this with restlet in a jetty container, following the spring security example. -- View this message in context:

Re: spring boot, jpa, entitymanagers and Java DSL

actually camel is pretty smart. if you create one and put it in the registry, it will find it by type and use it automatically. so in my startCamel code. I do this SimpleRegistry reg = new SimpleRegistry(); EntityManagerFactory factory =

Re: SMPP How to receive delivery receipt from smsc as producer?

Hello. Could you share code and messageProcessor deliveryReceiptProcessor? And then I have not come submit_sm_resp. ps: sorry if my english is very bad and there is an exception after sending an SMS to smsc. ( smsc gets my sms, a few seconds there is an exception in my application) WARN :

Getting Cannot determine current route from Exchange with id message

Hi, I'm currently working with camel 2.14.3 release and using camel-netty4-http and getting some strange behaviour: After using routing-slip and getting an error from the target endpoint, I'm getting the message: Cannot determine current route from Exchange with id: myId - 2 minutes after the

camel-smpp

Hello. I'm new to CAMEL-SMPP. I'm working on a project that requires smpp to send and receive sms from an smsc, i'm making a simulation using smsc from selenium. And when you send a sms (SMS comes to smsc), I expect submit_sm_resp and get this exception in my application. Help me please. ps:

Re: DeadLetterQueue -- Access the object before shutDown

Yes . i have to report the pending cases which are in queue,As the server restarted those cases wont be available in the queue fro resubmitting -- View this message in context: http://camel.465427.n5.nabble.com/DeadLetterQueue-Access-the-object-before-shutDown-tp5768069p5768244.html Sent from

Re: Using cxfrs producer with a dynamic endpoint from a metadata file

Thanks Yogesh for your prompt reply. Actually, my code worked :) I was checking the outbox folder and it had metadata.xml so I thought it was the same input file. I didn't check the contents of the file earlier. It does contain response from my external service, only that the fileName is inherited

Re: DeadLetterQueue -- Access the object before shutDown

Hi Claus , I'm using DeadLetterChannel .Please find my configuration errorHandler id=retryHandler type=DeadLetterChannel onRedeliveryRef=redeliveryLogger deadLetterUri=direct:email-error transactionManagerRef= redeliveryPolicy maximumRedeliveries={{standardRetryLimit}}

CronScheduled Route Policy is not working in cluster

Hi ., Can anyone help with cronscheduledouterpolicy in fuse 6.1 cluster. My camel file file looks like below., bean id=myStartPolicy class=org.apache.camel.routepolicy.quartz2.CronScheduledRoutePolicy property name=routeStartTime value=.. / property name=routeStopTime value=.. /

Re: Using cxfrs producer with a dynamic endpoint from a metadata file

Hello, Did you try using getOut().getBody() instead of getIn().getBody() for the cxf response? Regards, -Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/Using-cxfrs-producer-with-a-dynamic-endpoint-from-a-metadata-file-tp5768224p5768225.html Sent from the Camel -

null body after transform method exception

Hello all, When an exception is thrown from a transform method I lose the content of the message body. Is that intentional or a bug? Because it does not happen when an exception is thrown from a bean call. .bean(ErrorBean.class, ErrorBean.METHOD) Vs. .transform().method(ErrorBean.class,

Re: Using cxfrs producer with a dynamic endpoint from a metadata file

Glad things worked for you ... The other way you could try is by using Dynamic recipient list [1] for your cxfs endpoint instead of doing it via a processor. This way you could reduce on the boilerplate code and stick to camel's dsl Disclaimer: I haven't tried this with cxfrs :) [1]

Re: DeadLetterQueue -- Access the object before shutDown

Hi With dead letter queue, do you mean that Camel is currently handling redelivery and that those messages are queued because the redelivery has some delays and are therefore waiting for next attempt. And that during shutdown you want to know and access those pending messages ? On Mon, Jun 15,

Re: using TransactionErrorHandler with Camel and Karaf

You can use aries TX manager, but you need to use the spring api to setup it up. There are some TX example with blueprint on the internet / github repos. You may check the fuse by examples repos. On Sun, Jun 14, 2015 at 6:17 PM, yogu13 yog...@gmail.com wrote: Hello Claus, Sorry missed a tiny

Re: null body after transform method exception

Hi Ah no that is likely not the intention. Though as your bean uses some assertion are you sure its a regular java.lang.Exception and not a java.lang.Error that it throws. eg try with a regular exception. But still Camel should behave the same so there is likely a little bug. But I suspect its

RE: null body after transform method exception

Hi, Yes, I tried a wide range of exceptions ;) Nullpointers and such. But still, one test fails, the other succeeds. I would expect the same behavior from both methods. Thanks Claus! -Oorspronkelijk bericht- Van: Claus Ibsen [mailto:claus.ib...@gmail.com] Verzonden: Monday 15 June

Re: SMPP How to receive delivery receipt from smsc as producer?

Hello. Не могли бы вы поделиться кодом messageProcessor и deliveryReceiptProcessor? А то у меня не приходит submit_sm_resp. ps:sorry if my english is very bad -- View this message in context:

Re: using TransactionErrorHandler with Camel and Karaf

Hello Claus, Sorry missed a tiny detail we are using Aries Blueprint instead of Spring...Please let me know if it would still work Regards, -Yogesh On Sun, Jun 14, 2015 at 9:13 PM, Claus Ibsen-2 [via Camel] ml-node+s465427n5768210...@n5.nabble.com wrote: Hi You can do onException and

Re: Removing namespaces from soap response using SoapOutInterceptor

Hi, You can do this by xsl transformation., PFB xsl for removing namespace from a xml message., xsl:stylesheet version=1.0 xmlns:xsl=http://www.w3.org/1999/XSL/Transform; xsl:output omit-xml-declaration=yes indent=yes/ xsl:template match=* xsl:element name={local-name(.)}

RE: null body after transform method exception

Testcase (attachment was removed): package route; import org.apache.camel.Exchange; import org.apache.camel.LoggingLevel; import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.test.junit4.CamelTestSupport; import

Re: CronScheduled Route Policy is not working in cluster

Hi What do you mean by non working? Do you mean that the file consume should only be running on one active node, or what is your not working problem ? On Sun, Jun 14, 2015 at 6:51 PM, sathiyaraja sathiyaraja1...@hotmail.com wrote: Hi ., Can anyone help with cronscheduledouterpolicy in fuse

Re: null body after transform method exception

Hi And also tried with latest release? If so its a bug and you are welcome to log a JIRA http://camel.apache.org/support On Mon, Jun 15, 2015 at 9:29 AM, Hans Orbaan hans.orb...@docdata.eu wrote: Hi, Yes, I tried a wide range of exceptions ;) Nullpointers and such. But still, one test

Re: SMPP How to receive delivery receipt from smsc as producer?

Hello. Could you share code and messageProcessor deliveryReceiptProcessor? And then I have not come submit_sm_resp. ps: sorry if my english is very bad -- View this message in context: