Re: Path Parameters with REST DSL and Swagger

Try upgrade swagger-core to newer version On Wed, Mar 30, 2016 at 11:08 PM, Gregor Zurowski wrote: > Hi Everyone: > > I have a problem with path parameters when using the REST DSL with > Camel 2.16.2 and the camel-swagger-java module. Path parameters are > always exposed as enum types through Sw

camel-kafka 2.17 is not logging

i want to do if kafka server is not up then give connection exception then log exception and retry twice. i am using camel 2.17 kafka producer and i given kafka host name wrong still it not logging any exception and not retrying. if i use camel 2.16 it is logining exception. can you suggest on

converting xml fragment to java object

All, I'm trying to handle the response from a PayPal reporting xml request. Below is a fragment of the larger xml: #64 2 1 1000 55 Transaction ID string Time date ... ... ... I was trying to use the bold section of code to handle each row ( tag).

Re: Exception handling by main route to all sub routes

Thanks, it worked. -- View this message in context: http://camel.465427.n5.nabble.com/Exception-handling-by-main-route-to-all-sub-routes-tp5780084p5780097.html Sent from the Camel - Users mailing list archive at Nabble.com.

kafka message header reading.

how to read kafka message header while consuming message camel -Kafka as like enqueue message time-stamp. any way we con set header values in kafka message header so, we con read that value while consuming. -- View this message in context: http://camel.465427.n5.nabble.com/kafka-message-he

Camel Ldap, get body after getting exception

Hi. Im struggling with a ldap server which has referral problems. So returning with javax.naming.PartialResultException after my query. I've noticed that existing results of my query or not, the exception is always thrown, but i lose my result in the way. I've been using jxplorer to verify that th

cxf setting timeout

i am call web service using cxf endpoint in java dsl. i not able to set timeout for this call. from("direct:stratWS") .to("cxf:http://{{hostname}}/wserws?serviceClass=com.ws.class&defaultOperationName=methodname&continuationTimeout=1000";) .to("mock:wsResult")

Re: Instagram Component ?

In the past I used jinstagram from Camel, but never seen a componet. Will be nice to have one. B. On 28 March 2016 at 02:56, Mark wrote: > I'm currently investigating whether to use a 3rd party Java Instagram API > or write one from scratch for this component. None that I've found work > really

Path Parameters with REST DSL and Swagger

Hi Everyone: I have a problem with path parameters when using the REST DSL with Camel 2.16.2 and the camel-swagger-java module. Path parameters are always exposed as enum types through Swagger. The simplified REST part in my route builder looks as follows: === [...] rest("/test-api/v1").descrip

Re: Exception handling by main route to all sub routes

Change the error handler on routeB to the noErrorHandler http://camel.apache.org/error-handler.html > On Mar 30, 2016, at 12:09 PM, kumar5 wrote: > > routeA is calling routeB and routeA has Exception handling and set the > retry. If route B throw

Re: Camel - Consul integration

So that means the construct recipientsList cannot be used in conjunction with circuitbreaker? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Consul-integration-tp5780039p5780088.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel - Consul integration

For every message. And just return 1 endpoint it should use. If there is multiple avail in consult, then you can pick one random. If you return 2+ then the same message is sent to all those endpoints. http://camel.apache.org/recipient-list.html On Wed, Mar 30, 2016 at 8:18 PM, rogerhill01234 wro

Re: Camel - Consul integration

Thanks for the reply Claus. So I can use something like this? Will this code execute MessageRouter.routeTo() for every message? or only once for the router? from("direct:start").loadBalance() .circuitBreaker(2, 1000L, MyCustomException.class) .recipientList().method(MessageRouter.class

Exception handling by main route to all sub routes

routeA is calling routeB and routeA has Exception handling and set the retry. If route B throws exception then it doesn’t propagate to routeA. It means retry will not happen. Is it as design if yes is any way to propagate and main routeA can handle exception and retry -- View this messag

Re: camel 2.16.2 distributed tracing

Thanks lot Claus, I am looking into it. -- View this message in context: http://camel.465427.n5.nabble.com/camel-2-16-2-distributed-tracing-tp5779985p5780071.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel on OSGi - Get Bundle Name?

Thanks, both of you. I can't use the BlueprintBundleContext directly because I may not be running under Blueprint, but I'll figure something out from these leads. Claus, the common OsgiCamelContext idea sounds neat. Jens -- View this message in context: http://camel.465427.n5.nabble.com/Came

Re: Request to multiple routes

Hi, Ex: route("").to(bean1).to(bean2).to(bean3) Initial received HTTP request is sent to bean1 and the request will be part of exchange body. Post processing request in bean1 is it good practice to set a new response object in exchange which can be passed as input to bean2 directly or post tr

Re: Camel on OSGi - Get Bundle Name?

If you're trying to the get the bundle symbolic name when in your processor you can inject it at start up. The ref to the blueprintBundleContext is provided by default. You can get the bundle and symbolic name (and pretty much anything else) from it. I'm not sure if that's what you are

Memory leak with enrich("sql:select * from WhatEver")

Hi I’ve been working with Camel for the last few month. I have a program that processes several CVS files in order and inserts them into a DB. Once they are all inserted I have to check for duplicate and create new CVS files without duplicates. That is all working fine but I have one big pro

Re: camel 2.16.2 distributed tracing

You may want to take a look at the new camel-zipkin component http://camel.apache.org/camel-zipkin There is a little example here https://github.com/apache/camel/tree/master/examples/camel-example-zipkin On Tue, Mar 29, 2016 at 7:27 PM, kumar5 wrote: > I am using camel 2.16.2. how in intercepto

Re: Camel on OSGi - Get Bundle Name?

You can get the CamelContext and get that as BlueprintCamelContext and OsgiDefaultCamelContext for either of them. They have the bundle context. But it seems its maybe not exposed as a getter. We could add those so they have it. You can use the adapt method on camel context BlueprintCamelContex

Re: Camel on OSGi - Get Bundle Name?

Ranx wrote > There are a variety of ways to do that but what is it you are after > actually? There may be easier ways to accomplish what you are after. Are > you using Blueprint? One mechanism is the BlueprintListener. You can > also get the information and inject it during instantiation and I

Re: netty4-http: IllegalArgumentException: port out of range:-1

Hi Thanks for reporting. I have logged a ticket https://issues.apache.org/jira/browse/CAMEL-9779 On Wed, Mar 30, 2016 at 1:37 AM, kuro <962...@gmail.com> wrote: > camel 2.17.0 > > @Override > public void configure() throws Exception { > from("direct:in") > .setHeader

Re: Camel 2.17 camel-cdi injection problem

Hi Murt, > On 30 Mar 2016, at 17:00, murt_ryan wrote: > > Hi, > Apologies if my question is not clear but here goes: Your question is very clear ;) > I am currently experiencing problems with camel-cdi injection after moving > from Camel 2.16 to 2.17. I realise alot of work has gone on in thi

Re: Best Strategy to process a large number of rows in File

Are you eventually going to separate these queues in different locations? One thing that's happening when you use JMS this way is you read the records in, and then you immediately write them back out over a socket and then read them back in. Those all involve duplication of memory. Since you m

Re: Camel 2.17 Kafka SSL Producer and Consumer

I was able to consume, using ssl and the schema registry. I however did not get the messages which where produced before I started the consuming, this is because it default to 'auto.offset.reset = latest', this is a Camel default, which you can change by adding 'autoOffsetReset=earliest' to the pro

Camel 2.17 camel-cdi injection problem

Hi, Apologies if my question is not clear but here goes: I am currently experiencing problems with camel-cdi injection after moving from Camel 2.16 to 2.17. I realise alot of work has gone on in this area in this new release. I am trying to run camel as part of JBoss EAP 6.4 (I cannot use Wildfl

Re: Camel on OSGi - Get Bundle Name?

There are a variety of ways to do that but what is it you are after actually? There may be easier ways to accomplish what you are after. Are you using Blueprint? One mechanism is the BlueprintListener. You can also get the information and inject it during instantiation and I think the Framework

Re: CamelContext.hasComponent()

I'm looking at code that conditionally adds activemq if configuration is provided at runtime, hence my use as a consumer. On 30 March 2016 at 11:25, Claus Ibsen wrote: > Just to add a bit context. > > This method is less intended for Camel end users, but more for > component developers / camel i

Re: Best Strategy to process a large number of rows in File

Hi, yes... it is clear ;)! I changed configuration of Heap and Perm progressively as you suggested like this: -server -Xms1024M -Xmx2048M -XX:PermSize=256M -XX:MaxPermSize=512M -Xss512M -XX:+HeapDumpOnOutOfMemoryError -verbose:gc -Xloggc:gc.log ... The number of rows processed has increased,

How to process Multipart SOAP response

Hi Camel team, Jboss Fuse Studio : Version: 8.1.0.GA Jdk version: 1.8.0_73 Using XML DSL No server involved. since i am yet trying to run camel context locally on dev studio I am trying to connect send and receive a SOAP request&response message to a third party webservice(Oracle). I am suc

Camel on OSGi - Get Bundle Name?

Hi, I'm running Camel in an OSGi container (Karaf). I'd like to get hold of the OSGi bundle (or bundle name) that the route (or the context) belongs to in one of my processors. Is there a way to get that information somehow? Thanks, Jens -- View this message in context: http://camel.465427.n

Re: Camel - Consul integration

I can't speak to Consul, but have a look at Camel's Recipient List[0], it's exactly what you want for dynamic recipients. Doug [0] http://camel.apache.org/recipient-list.html On Wed, Mar 30, 2016 at 7:35 AM, rogerhill01234 wrote: > Is there a way to leverage Consul for service discovery in Cam

Re: Camel - Consul integration

There is an external camel-consul component. Not sure what functions it provides, but you can take a look https://github.com/bprager/camel-consul For the Camel endpoints in the CB you can use recipinent list / toD as dynamic to, where you can have an expression / bean etc that lookup in consul and

How to process Multipart SOAP response

Hi Camel team, Jboss Fuse Studio : Version: 8.1.0.GA Jdk version: 1.8.0_73 Using XML DSL No server involved. since i am yet trying to run camel context locally on dev studio I am trying to connect send and receive a SOAP request&response message to a third party webservice(Oracle). I am s

Integration of camel with spring mvc

Hi... As i am a beginner i need to know the steps to integrate camel with spring mvc for a web service application. Please help me with the detailed steps as soon as possible, Its urgent -- View this message in context: http://camel.465427.n5.nabble.com/Integration-of-camel-with-spring-mvc-tp57

Camel - Consul integration

Is there a way to leverage Consul for service discovery in Camel routes? For example, in the code below, how can I make the "to" end points cognizant of Consul services? from("direct:start").loadBalance() .circuitBreaker(2, 1000L, MyCustomException.class) .to("http://hostname1:port/resourc

RE: Camel ftp component : JSCH-0.1.44 Vs OpenSSH_6.6.1 issue: Leads to error : com.jcraft.jsch.JSchException: Session.connect: java.io.IOException: End of IO Stream Read

Hi, The code I sent is for camel-ftp. It uses static methods to do those changes in JSch. But after looking at your stacktrace in a browser and not my email client I am sure you are facing different issues then we were. What I did was hooking up my debugger and line for line walk with my thread

Re: Seda concurrent consumers with aggregator

Hi That will only concurrently send in messages into the aggregator. The aggregation happens single threaded by default (unless you turn on optimisticLocking). You can turn on parallel processing on the aggragator so outgouing messages can be processed concurrently. There is options to configure

RE: Camel ftp component : JSCH-0.1.44 Vs OpenSSH_6.6.1 issue: Leads to error : com.jcraft.jsch.JSchException: Session.connect: java.io.IOException: End of IO Stream Read

Hi Claus, Hans, We are using Camel FTP component (http://camel.apache.org/ftp2.html) to connect with FTP server. We are not directly using "Jsch". I understand that Camel-ftp component make use of "Jsch" library internally. Do we need to change something or configure "Jsch" internally? We start

Seda concurrent consumers with aggregator

Is it valid to concurrently process messages into an aggregator? There is no mention of "aggregator" in Camel docs for parallel processing, want to be sure. true -- View this message in context: http://camel.465427.n5.nabble.com/

RE: Camel ftp component : JSCH-0.1.44 Vs OpenSSH_6.6.1 issue: Leads to error : com.jcraft.jsch.JSchException: Session.connect: java.io.IOException: End of IO Stream Read

HI, I am not sure if you have the same issue with Jsch as we had, but give this a go: {code} { // change the order of PreferredAuthentications. put gssapi-with-mic as last String preferredAuthentications = JSch.getConfig("PreferredAuthentications").replace("gssapi-with-mic"

Re: Camel ftp component : JSCH-0.1.44 Vs OpenSSH_6.6.1 issue: Leads to error : com.jcraft.jsch.JSchException: Session.connect: java.io.IOException: End of IO Stream Read

Give it a try. You can download the latest version and try it with Camel only as you desire to do. Also mind that Camel does not do the actual SSH/JSCH implementation. It may also be an issue with that library so upgrading it or reporting to that community may help. On Wed, Mar 30, 2016 at 2:17

Re: Camel ftp component : JSCH-0.1.44 Vs OpenSSH_6.6.1 issue: Leads to error : com.jcraft.jsch.JSchException: Session.connect: java.io.IOException: End of IO Stream Read

Hi Claus, Thanks for replying. We are planning to get rid of Fuse, ServiceMix and planning to use Camel only solution. Do you think Camel latest version have SSH/JSCH issue fixed. That is we do not face such issue with "Camel only" solution? I suppose, now I am asking question in right forum.

Re: 2.17.0 - Camel Swagger Java Example?

Thank you Claus :) Il mer 30 mar 2016, 11:53 Claus Ibsen ha scritto: > There are plenty of swagger examples, its the swagger-xml for xml dsl, > and -cdi for java based > > On Wed, Mar 30, 2016 at 11:49 AM, Giorgio Vespucci > wrote: > > Dear all, > > I cannot find anymore the Camel Swagger Java

camel invoking rest endpoint two times

When I call aiRsServer, it call restClient which calls the nRsServer's login endpoint but the execution comes to the login endpoint implementation two time, Please find my soapcontext as below, http://www.springframework.org/schema/beans"; xmlns:cxf="http://camel.apache.org/schema/cxf";

Re: CamelContext.hasComponent()

Just to add a bit context. This method is less intended for Camel end users, but more for component developers / camel itself. On Wed, Mar 30, 2016 at 12:00 PM, Claus Ibsen wrote: > No this is by design > > On Wed, Mar 30, 2016 at 11:56 AM, James Green > wrote: >> I was expecting this to retu

Re: CamelContext.hasComponent()

No this is by design On Wed, Mar 30, 2016 at 11:56 AM, James Green wrote: > I was expecting this to return boolean, but it returns a Component if > present or null otherwise. > > This feels counter-intuitive and horrible to code against. Are there plans > to this this? > > Thanks, > > James --

CamelContext.hasComponent()

I was expecting this to return boolean, but it returns a Component if present or null otherwise. This feels counter-intuitive and horrible to code against. Are there plans to this this? Thanks, James

Re: 2.17.0 - Camel Swagger Java Example?

There are plenty of swagger examples, its the swagger-xml for xml dsl, and -cdi for java based On Wed, Mar 30, 2016 at 11:49 AM, Giorgio Vespucci wrote: > Dear all, > I cannot find anymore the Camel Swagger Java example at: > https://github.com/apache/camel/tree/master/examples. > The latest one

2.17.0 - Camel Swagger Java Example?

Dear all, I cannot find anymore the Camel Swagger Java example at: https://github.com/apache/camel/tree/master/examples. The latest one I found is at: http://mvnrepository.com/artifact/org.apache.camel/camel-example-swagger-java/2.16.2 . Is it still valid for the latest 2.17.0 version? Thanks

Help tell Pivotal to accept Apache Camel as a choice on start.spring.io

Hi With the Apache Camel 2.17.0 release we have a camel-spring-boot-starter module that has the naming and convention that Spring Boot advises. What would be good is to get Pivotal to add Apache Camel to the list of choices in the start.spring.io web application. I have created a github PR with

Re: Best Strategy to process a large number of rows in File

and I launch JB Fuse with VM Arguments > -server -Xms256M -Xss512M -Xmx512M -XX:+UnlockDiagnosticVMOptions > -XX:+UnsyncloadClass -XX:PermSize=512M -XX:MaxPermSize=1024M > -Dorg.apache.activemq.UseDedicatedTaskRunner=false > > That's all... > > I tried the same proces

Re: Best Strategy to process a large number of rows in File

da with Active MQ and soon I have seen in the log file 09:23:58,948 | ERROR | Inbound_Worker-2 | DefaultErrorHandler | 198 - org.apache.camel.camel-core - 2.15.1.redhat-620133 - IF_INGESTATE-Inbound-Context - IMP-IF-Ingestate-20160330-090900 | Failed delivery for (MessageId: ID-FGBAL

Re: Best Strategy to process a large number of rows in File

I forgot this link http://activemq.apache.org/what-is-the-prefetch-limit-for.html and so I changed the consumer endpoint like this Thanks again. Regards Michele -- View this message in context: http://camel.465427.n5.nabble.com/Best-Strategy-to-process-a-large-number-of-rows-in-File

Re: PDF/A files using Camel FOP component

Hi Ibryam, I tried that header but it doesn't seem to work. The output looks the same (same number of bytes, doesn't pass the PDF/A checks http://www.pdf-tools.com/pdf/validate-pdfa-online.aspx) PDF/A-1b Do you have other ideas? Regards, Laurentiu On Tue, Mar 29, 2016 at 10:46 PM, Bilgin Ibr