Re: jaxb non-thread safe issue
Try and test with latest Camel release. On Wed, Mar 5, 2014 at 7:02 AM, simafengyun yifeng@citi.com wrote: Hi, Thanks for your quick reponse. I used camel 2.10.4. Sorry, I didn't introduce my issue in detail. Actually, in the route marketDataRoute, it get message from jms queue, and the jms message will be encapsulated to java object in the jmsProcessor them the object will be sent to seda queue. camel:route id=marketDataRoute from ref=marketDataQueue / to id=ToJmsProcessor uri=jmsProcessor/ to uri=toMarshal / /camel:route in the route jaxbRoute, it just get the java object from seda queue, then marshall the data to xml. these objects are not shared, they are independent objects. -- View this message in context: http://camel.465427.n5.nabble.com/jaxb-non-thread-safe-issue-tp5748274p5748313.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
Re: Camel CXF RS
Hi, You can dig starting from here: https://github.com/Tcharl/net.osgiliath.hello/blob/master/net.osgiliath.hello.routes/src/main/java/net/osgiliath/hello/routes/HelloRoute.java . REGARDS, 2014-03-04 19:16 GMT+01:00 CamelTester vijaykonje...@gmail.com: Hi, Can anyone give an complete camel CXF RS example? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-CXF-RS-tp5748301.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Cordialement, Charlie Mordant
Re: deploying Camel integrations in Jboss
Hi Well smooks is on the classpath somewhere org.milyn.smooks.camel.converters If you do not use/need it, then try to find where its coming from and remove it. On Tue, Mar 4, 2014 at 7:54 PM, nicoletta nicolettatri...@msn.com wrote: Hello, I am simply using the mentioned example. It uses a transform tag: could it use smooks? However, I have modified the config in the following way, and I still have the same error. I have another question: how could I deploy an integration not involving servlets (so, not requiring a war archive)? * beans xmlns=http://www.springframework.org/schema/beans; xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance; xmlns:camel=http://camel.apache.org/schema/spring; xsi:schemaLocation= http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd; camelContext xmlns=http://camel.apache.org/schema/spring; route id=helloRoute from uri=servlet:///hello/ choice when headername/header to uri=file:/home/nicoletta/test1/ /when otherwise to uri=file:/home/nicoletta/test2/ /otherwise /choice /route /camelContext /beans* -- View this message in context: http://camel.465427.n5.nabble.com/deploying-Camel-integrations-in-Jboss-tp5748289p5748302.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
Re: camel-xmlrpc response not showing
Hi Willem, I sorted issue, Apache camel is not providing response if it contain any exception from server like following, but it suppose to send back response to processor, its not HTTP error. Or i suppose to handle such errors with some onException ?xml version=1.0 encoding=utf-8? methodResponse fault value struct member namefaultCode/name valuei41003/i4/value /member member namefaultString/name valuestringData out of bounds/string/value /member /struct /value /fault /methodResponse Regards -- View this message in context: http://camel.465427.n5.nabble.com/camel-xmlrpc-response-not-showing-tp5748275p5748319.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel CXF - SOAP 1.1 vs SOAP 1.2
Can you setup the wsdlUrl attribute of the cxfEndpoint, in this way camel-cxf can pick up right soap binding version for you. -- 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 March 5, 2014 at 3:23:38 PM, fs (mholla...@gmail.com) wrote: Btw, if change the cxf-endpoint dataFormat to PAYLOAD I get the following soap fault. It seems that the cxf-endpoint is seen as a SOAP 1.1 endpoint for some reason? soap:VersionMismatch A SOAP 1.2 message is not valid when sent to a SOAP 1.1 only endpoint. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-CXF-SOAP-1-1-vs-SOAP-1-2-tp5748285p5748315.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel CXF - SOAP 1.1 vs SOAP 1.2
You can setup the soap binding just like this.
cxf:cxfEndpoint id=myEndpoint
address=http://localhost:${CXFTestSupport.port3}/test;
serviceClass=org.apache.camel.wsdl_first.Person
serviceName=${CxfEndpointBeans.serviceName}
endpointName=${CxfEndpointBeans.endpointName}
wsdlURL=person.wsdl loggingFeatureEnabled=true loggingSizeLimit=200
cxf:binding
soap:soapBinding version=1.2/
/cxf:binding
/cxf:cxfEndpoint
or just add below lines to SEI (foo.bar.FooBarPort)
@BindingType(SOAPBinding.SOAP12HTTP_BINDING)
--
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 March 5, 2014 at 5:05:25 PM, Willem Jiang (willem.ji...@gmail.com) wrote:
Can you setup the wsdlUrl attribute of the cxfEndpoint, in this way camel-cxf
can pick
up right soap binding version for you.
--
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 March 5, 2014 at 3:23:38 PM, fs (mholla...@gmail.com) wrote:
Btw, if change the cxf-endpoint dataFormat to PAYLOAD I get the following
soap fault.
It seems that the cxf-endpoint is seen as a SOAP 1.1 endpoint for some
reason? soap:VersionMismatch
A SOAP 1.2 message is not valid when sent to a SOAP 1.1 only endpoint. --
View this message
in context:
http://camel.465427.n5.nabble.com/Camel-CXF-SOAP-1-1-vs-SOAP-1-2-tp5748285p5748315.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel CXF - SOAP 1.1 vs SOAP 1.2
Yes, the soap:soapBinding version=1.2/ seems to do the trick. But only after taking the correct namespace http://cxf.apache.org/blueprint/bindings/soap into use. Now we get soap fault in the SOAP 1.2 format. Thanks a lot for the help! -- View this message in context: http://camel.465427.n5.nabble.com/Camel-CXF-SOAP-1-1-vs-SOAP-1-2-tp5748285p5748322.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel CXF RS
Or try this very good tutorial project https://github.com/santoshjoshi/camel-cxfrs-example On Tue, Mar 4, 2014 at 10:22 PM, Charlie Mordant cmorda...@gmail.comwrote: Hi, You can dig starting from here: https://github.com/Tcharl/net.osgiliath.hello/blob/master/net.osgiliath.hello.routes/src/main/java/net/osgiliath/hello/routes/HelloRoute.java . REGARDS, 2014-03-04 19:16 GMT+01:00 CamelTester vijaykonje...@gmail.com: Hi, Can anyone give an complete camel CXF RS example? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-CXF-RS-tp5748301.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Cordialement, Charlie Mordant
Re: Howto find similar ftp endpoints by routeId
Hi 1) Each consumer created by the endpoint is single threaded, and has their own FtpClient which they use for communicating with the FTP server. And the FtpClient does not support concurrency (eg only download a single file at a time etc.) But you can have mutliple routes from the same ftp endpoint, and therefore create multiple consumers, which their own FtpClient instance. And therefore simulate concurrency.. What people maybe would like to do is to have 1 route, but say ?concurrentConsumers=5 to be able to download multiple files at the same time. This is currently not supported. 2) There is API on CamelContext to get all the routes, and then you can get which endpoint they have as input. On Tue, Mar 4, 2014 at 5:35 PM, robin.lut...@t-systems.com wrote: Hi Claus, regarding to this i have some questions: 1. What does endpoint in this case mean? - the full uri - or only the server address 2. is there a simple way in java to find any route in context, which is active using the same endpoint as the routeId which user wants to start? - in our case there are many consumer routes, which will be started by ejb timer by routeId. My Idea is now, to look for any active route using the same endpoint and wait until they are finished. Regards Robin -Ursprüngliche Nachricht- Von: Claus Ibsen [mailto:claus.ib...@gmail.com] Gesendet: Donnerstag, 20. Februar 2014 16:46 An: users@camel.apache.org Betreff: Re: Multiple connections Camel FTP Client The ftp consumer in Camel is single threaded. There is a information box at this page that tells that http://camel.apache.org/ftp2 -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
Re: Camel CXF RS
Unfortunately that tutorial only showcases Camel as a client, but not as a service provider. If you want to build a JAX-RS service, I suggest you use the new SimpleBinding to make sure that your @HeaderParams, @PathParams, @QueryParams, etc. are injected as Camel headers, and that your request payload is injected as the Camel IN message body. This will rid you of manually processing a MessageContentsList object and tightly coupling your route implementation to the order of parameters in the JAX-RS method signature. More info in our camel-cxfrs Wiki page. Regards, *Raúl Kripalani* Apache Camel PMC Member Committer | Enterprise Architect, Open Source Integration specialist http://about.me/raulkripalani | http://www.linkedin.com/in/raulkripalani http://blog.raulkr.net | twitter: @raulvk On Wed, Mar 5, 2014 at 10:14 AM, David Parker dfpar...@gmail.com wrote: Or try this very good tutorial project https://github.com/santoshjoshi/camel-cxfrs-example On Tue, Mar 4, 2014 at 10:22 PM, Charlie Mordant cmorda...@gmail.com wrote: Hi, You can dig starting from here: https://github.com/Tcharl/net.osgiliath.hello/blob/master/net.osgiliath.hello.routes/src/main/java/net/osgiliath/hello/routes/HelloRoute.java . REGARDS, 2014-03-04 19:16 GMT+01:00 CamelTester vijaykonje...@gmail.com: Hi, Can anyone give an complete camel CXF RS example? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-CXF-RS-tp5748301.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Cordialement, Charlie Mordant
Re: using CSV Bindy data format
Hi, Thanks for the reply. I cant see the option for omitting quotes for empty values in Bindy page. I always get csv record as some Value,, insteadof some value,, Could you please help. Regards, CGSK -- View this message in context: http://camel.465427.n5.nabble.com/using-CSV-Bindy-data-format-tp5748261p5748326.html Sent from the Camel - Users mailing list archive at Nabble.com.
Spring WS and Soap Action
Hello,
We currently are using REST component and SOAP component for receiving
messages within our application.
The below part of the camel configuration has a dynamic URL for the restlet
call and part of the URI is used within the onMessage of the bean. The below
works fine and makes it easy to define one route for all incoming rest calls
and within the bean we can address / find the correct code.
camel:route
camel:from
uri=restlet:/{endpoint}/{storeidentifier}/search?restletMethod=#getMethod
/
camel:to uri=bean:someBean?method=onMessage(${header.endpoint}) /
/camel:route
If we try the same for Spring WS with a soapAction. It will not find the
endpoint. Because the
org.apache.camel.component.spring.ws.bean.CamelEndpointMapping.getEndpointInternal(MessageContext)
does not resolve the dynamic part.
camel:from
uri=spring-ws:soapaction:{endpoint}?endpointMapping=#endpointMapping /
I can solved it by using the spring-ws:uri mapping type and create a
processor for retrieving the soap action.
My question is the above solution the only way to go or do i miss something?
Also it would be great if the SpringWSConsumer makes the HTTP Headers
available as headers (same as the restlet component)
Kind regards,
Richard
--
View this message in context:
http://camel.465427.n5.nabble.com/Spring-WS-and-Soap-Action-tp5748327.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: how to do redelivery message
But processorService is an OSGi service. I can't check null value in this step. Wrap the service in other bean or processor and let it do the check / throw exception. Cheers. -- Henryk Konsek http://henryk-konsek.blogspot.com
Re: camel-dropbox
I need also to include files that matches the regex pattern (like the include option in file component). Is that possible? DropBox component is not maintained by the Apache team. We could answer your question after it will be donated to ASF :) . For now I don't know where to find its sources nor its documentation. Cheers. -- Henryk Konsek http://henryk-konsek.blogspot.com
AW: Howto find similar ftp endpoints by routeId
Hi Claus, thanks for your response. 1) that means following is possible? - Route A: from(ftp://server1/directory1/?username=userpassword=RAW(pwd)).to(direct:consumer); - Route B: from(ftp://server1/directory1/?username=userpassword=RAW(pwd)).to(direct:consumer); We have some issues with different routes consuming many files parallel from one server and I thought the single threaded behavior could be the cause. One Isssue is Route B is hanging without any indication. 2) my hope was you have a simple short cut (: Regards Robin -Ursprüngliche Nachricht- Von: Claus Ibsen [mailto:claus.ib...@gmail.com] Gesendet: Mittwoch, 5. März 2014 11:30 An: users@camel.apache.org Betreff: Re: Howto find similar ftp endpoints by routeId Hi 1) Each consumer created by the endpoint is single threaded, and has their own FtpClient which they use for communicating with the FTP server. And the FtpClient does not support concurrency (eg only download a single file at a time etc.) But you can have mutliple routes from the same ftp endpoint, and therefore create multiple consumers, which their own FtpClient instance. And therefore simulate concurrency.. What people maybe would like to do is to have 1 route, but say ?concurrentConsumers=5 to be able to download multiple files at the same time. This is currently not supported. 2) There is API on CamelContext to get all the routes, and then you can get which endpoint they have as input. On Tue, Mar 4, 2014 at 5:35 PM, robin.lut...@t-systems.com wrote: Hi Claus, regarding to this i have some questions: 1. What does endpoint in this case mean? - the full uri - or only the server address 2. is there a simple way in java to find any route in context, which is active using the same endpoint as the routeId which user wants to start? - in our case there are many consumer routes, which will be started by ejb timer by routeId. My Idea is now, to look for any active route using the same endpoint and wait until they are finished. Regards Robin -Ursprüngliche Nachricht- Von: Claus Ibsen [mailto:claus.ib...@gmail.com] Gesendet: Donnerstag, 20. Februar 2014 16:46 An: users@camel.apache.org Betreff: Re: Multiple connections Camel FTP Client The ftp consumer in Camel is single threaded. There is a information box at this page that tells that http://camel.apache.org/ftp2 -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
Re: using CSV Bindy data format
To help you, we need that you share an example somewhere. On Wed, Mar 5, 2014 at 12:05 PM, cgsk karthik2...@gmail.com wrote: Hi, Thanks for the reply. I cant see the option for omitting quotes for empty values in Bindy page. I always get csv record as some Value,, insteadof some value,, Could you please help. Regards, CGSK -- View this message in context: http://camel.465427.n5.nabble.com/using-CSV-Bindy-data-format-tp5748261p5748326.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Charles Moulliard Apache Committer / Architect @RedHat Twitter : @cmoulliard | Blog : http://cmoulliard.github.io
Property placeholder and JNDI
I am running a number of Spring XML routes on a JEE server. I would like to configure parts of the uri:s used in the routes via ENC entries in my application (war). In my web.xml I have a number of env-entry declarations that holds the values to be injected into the uri:s of my routes. Is there already some way to do this or that provides pieces of the solution ? Thanks Lars -- View this message in context: http://camel.465427.n5.nabble.com/Property-placeholder-and-JNDI-tp5748334.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: deploying Camel integrations in Jboss
Thanks Claus, I have no smooks in the classpath for what I am concerned. So, I tried the opposite of your suggestion: I added smooks-all-1.5.1 to the dependency of the project (thus, to the lib dir of the war). And this time the error is the following: *[/camel-example-servlet-tomcat-2.12.3]] [HDScanne r] Exception sending context initialized event to listener instance of class org.springframework.web.context.ContextLoaderListener: org.springf ramework.beans.factory.BeanDefinitionStoreException: Unexpected exception parsing XML document from class path resource [camel-config.xml]; nes ted exception is java.lang.LinkageError: loader constraint violation in interface itable initialization: when resolving method org.apache.xerc es.dom.NodeImpl.setUserData(Ljava/lang/String;Ljava/lang/Object;Lorg/w3c/dom/UserDataHandler;)Ljava/lang/Object; the class loader (instance of org/jboss/classloader/spi/base/BaseClassLoader) of the current class, org/apache/xerces/dom/NodeImpl, and the class loader (instance of bootloader) for interface org/w3c/dom/Node have different Class objects for the type org/w3c/dom/UserDataHandler used in the signature* My next step if I will not find a solution is to try the deploy on a newest version of jboss (e.g. 7.1.1 final). -- View this message in context: http://camel.465427.n5.nabble.com/deploying-Camel-integrations-in-Jboss-tp5748289p5748330.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: deploying Camel integrations in Jboss
On Tue, Mar 4, 2014 at 4:15 PM, nicoletta nicolettatri...@msn.com wrote: Hello everybody, I have to deploy camel integration projects on jboss as 6. I've read many other threads about this, but I cannot find the solution. As a first step, I am trying to deploy the examples/camel-example-servlet-tomcat of Camel 2.12.3 on jboss as 6. I've created the war package through the mvn package utility and I copied it in the deploy directory of jboss. Unfortunately, the deployment had no success, because I am getting the following error: * org.apache.camel.TypeConverterLoaderException: Failed to load type converters because of: Cannot find any type converter classes from the following packages: [org.milyn.smooks.camel.converters, org.apache.camel.component.file, org.apache.camel.component.bean, org.apache.camel.converter].* I have also inserted the META-INF/services/org/apache/camel/TypeConverter file with the following content: /org.milyn.smooks.camel.converters, org.apache.camel.component.file, org.apache.camel.component.bean, org.apache.camel.converter/. Why did you do that? You should not touch any of these files, and just build and deploy the WAR as is. Can somebody help me in this task? I am not finding a working guide to jboss/camel integration. Thanks, Nicoletta -- View this message in context: http://camel.465427.n5.nabble.com/deploying-Camel-integrations-in-Jboss-tp5748289.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
Re: How to prevent ftp from creating ID- file?
hmm... I need my direct:MoveUpload b/c it's called from various other routes.
It's a generic route. Is there another way?
One approach might be to filter out the unwanted file. There's no
include/exclude on FTP. I'm using java dsl so can't use ANT filter. I could
use GenericFilter i suppose. But is there a more standard way to deal with
this?
Would it be your suggestion that rather than use
from(direct:moveUpload)
.log(@@@ MoveUpload: Using properties: + propsId)
.from(file://{{move.from.dir}}?noop=true)
.recipientList(simple(ftp://{{move.to.user}}@{{move.to.host}}/{{move.to.dir}}?password={{move.to.pwd}}{{move.to.uriparams}};))
I just use
from(file://{{move.from.dir}}?noop=true)
.recipientList(simple(ftp://{{move.to.user}}@{{move.to.host}}/{{move.to.dir}}?password={{move.to.pwd}}{{move.to.uriparams}};))
? If so, how would I use this flow as a part of a larger flow, in which i
branch from some other route to this one?
thanks for your time and thoughts.
--
View this message in context:
http://camel.465427.n5.nabble.com/How-to-prevent-ftp-from-creating-ID-file-tp5748344p5748350.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Fw: software dev architecture at ApacheCon Denver
Hello software dev architecture Enthusiasts, As you are no doubt aware, ApacheCon North America will be held in Denver, Colorado starting on April 7th. Software dev architecture has 14 talks; check it out here: http://apacheconnorthamerica2014.sched.org/overview/type/software+dev+%26+architecture#.UxccPYV9JUE We would love to see you in Denver next month. Register soon, as prices go up on March 14th. http://na.apachecon.com/. Best regards, Melissa ApacheCon Planning Team
Re: How to prevent ftp from creating ID- file?
Hi
Yeah see the filter eip to filter out when you use direct:xxx
http://camel.apache.org/message-filter.html
On Wed, Mar 5, 2014 at 6:16 PM, mister blinky misterbli...@gmail.com wrote:
hmm... I need my direct:MoveUpload b/c it's called from various other routes.
It's a generic route. Is there another way?
One approach might be to filter out the unwanted file. There's no
include/exclude on FTP. I'm using java dsl so can't use ANT filter. I could
use GenericFilter i suppose. But is there a more standard way to deal with
this?
Would it be your suggestion that rather than use
from(direct:moveUpload)
.log(@@@ MoveUpload: Using properties: + propsId)
.from(file://{{move.from.dir}}?noop=true)
.recipientList(simple(ftp://{{move.to.user}}@{{move.to.host}}/{{move.to.dir}}?password={{move.to.pwd}}{{move.to.uriparams}};))
I just use
from(file://{{move.from.dir}}?noop=true)
.recipientList(simple(ftp://{{move.to.user}}@{{move.to.host}}/{{move.to.dir}}?password={{move.to.pwd}}{{move.to.uriparams}};))
? If so, how would I use this flow as a part of a larger flow, in which i
branch from some other route to this one?
thanks for your time and thoughts.
--
View this message in context:
http://camel.465427.n5.nabble.com/How-to-prevent-ftp-from-creating-ID-file-tp5748344p5748350.html
Sent from the Camel - Users mailing list archive at Nabble.com.
--
Claus Ibsen
-
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
Make your Camel applications look hawt, try: http://hawt.io
Re: Howto find similar ftp endpoints by routeId
What version of Camel do you use? On Wed, Mar 5, 2014 at 3:29 PM, robin.lut...@t-systems.com wrote: Hi Claus, thanks for your response. 1) that means following is possible? - Route A: from(ftp://server1/directory1/?username=userpassword=RAW(pwd)).to(direct:consumer); - Route B: from(ftp://server1/directory1/?username=userpassword=RAW(pwd)).to(direct:consumer); We have some issues with different routes consuming many files parallel from one server and I thought the single threaded behavior could be the cause. One Isssue is Route B is hanging without any indication. 2) my hope was you have a simple short cut (: Regards Robin -Ursprüngliche Nachricht- Von: Claus Ibsen [mailto:claus.ib...@gmail.com] Gesendet: Mittwoch, 5. März 2014 11:30 An: users@camel.apache.org Betreff: Re: Howto find similar ftp endpoints by routeId Hi 1) Each consumer created by the endpoint is single threaded, and has their own FtpClient which they use for communicating with the FTP server. And the FtpClient does not support concurrency (eg only download a single file at a time etc.) But you can have mutliple routes from the same ftp endpoint, and therefore create multiple consumers, which their own FtpClient instance. And therefore simulate concurrency.. What people maybe would like to do is to have 1 route, but say ?concurrentConsumers=5 to be able to download multiple files at the same time. This is currently not supported. 2) There is API on CamelContext to get all the routes, and then you can get which endpoint they have as input. On Tue, Mar 4, 2014 at 5:35 PM, robin.lut...@t-systems.com wrote: Hi Claus, regarding to this i have some questions: 1. What does endpoint in this case mean? - the full uri - or only the server address 2. is there a simple way in java to find any route in context, which is active using the same endpoint as the routeId which user wants to start? - in our case there are many consumer routes, which will be started by ejb timer by routeId. My Idea is now, to look for any active route using the same endpoint and wait until they are finished. Regards Robin -Ursprüngliche Nachricht- Von: Claus Ibsen [mailto:claus.ib...@gmail.com] Gesendet: Donnerstag, 20. Februar 2014 16:46 An: users@camel.apache.org Betreff: Re: Multiple connections Camel FTP Client The ftp consumer in Camel is single threaded. There is a information box at this page that tells that http://camel.apache.org/ftp2 -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
Re: Using Camel properties
You could subclass org.apache.camel.component.properties.DefaultPropertiesParser and set it as the propertiesParser in your PropertiesComponent. Your subclass could handle the missing property and just return null. -- View this message in context: http://camel.465427.n5.nabble.com/Using-Camel-properties-tp5748299p5748353.html Sent from the Camel - Users mailing list archive at Nabble.com.
FTP Move fails - have found cause but don't understands why
Hi,
I am used camel 2.12.3
I am using an FTP consumer.
ftp.mysite.com/mydir/mydir2?username=abcpassword=abcstreamDownload=truemove=.donedelay=60
There is a file in /mydir/mydir2 named xxx.xxx but the move fails. I
debugged the code and found the cause.
In org.apache.camel.component.file.remote at line 255 the rename is executed
public boolean renameFile(String from, String to) throws
GenericFileOperationFailedException {
log.debug(Renaming file: {} to: {}, from, to);
try {
*return client.rename(from, to);*
} catch (IOException e) {
throw new
GenericFileOperationFailedException(client.getReplyCode(),
client.getReplyString(), e.getMessage(), e);
}
}
the from is /mydir/mydir2/xxx.xxx and the to is /mydir/mydir2/.done/xxx.xxx
the 'client' in line 255 is org.apache.commons.net.ftp.FTPClient.rename(...)
org.apache.commons.net is version 3.3 (as per the camel pom)
That code org.apache.commons.net.ftp.FTPClient.rename line 2557 looks like
this
public boolean rename(String from, String to) throws IOException
{
*if (!FTPReply.isPositiveIntermediate(rnfr(from))) {
return false;*
}
return FTPReply.isPositiveCompletion(rnto(to));
}
So, FTPClient does the rename in two steps - rnfr and rnto.
when rnfr executes it send RNFR /mydir/mydir2/xxx.xxx to the ftp server.
The ftp server response back with the reply 250 Directory successfully
changed.
so rnft(from), which return an int, with return 250.
However the code in isPositiveIntermediate looks like this...
public static boolean isPositiveIntermediate(int reply)
{
return (reply = 300 reply 400);
}
so, the return code from 250 Directory successfully changed. will return
false as it is not between 300 and 399 and the seconds step for the rename
rnto(to) never executes and *false*is returned to camel which then thrown a
GenericFileOperationFailedException
It seems to me that the reply from the ftp server of 250 Directory
successfully changed. should be OK for the RNFR step of
org.apache.commons.net.ftp.FTPClient.rename.
I have to believe others have run into this?
Any advise?
Regards
Ron Bogdanoff
--
View this message in context:
http://camel.465427.n5.nabble.com/FTP-Move-fails-have-found-cause-but-don-t-understands-why-tp5748358.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel Routes - Multi threading nor running parallel
Hello Hema, Have you had a luck to resolve this...? I am having similar issue... -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Routes-Multi-threading-nor-running-parallel-tp5721385p5748359.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Using Camel properties
There is an option you can turn on the properties component to tell it to ignore unknown property keys. On Wed, Mar 5, 2014 at 8:01 PM, swwyatt steven.wy...@sungard.com wrote: You could subclass org.apache.camel.component.properties.DefaultPropertiesParser and set it as the propertiesParser in your PropertiesComponent. Your subclass could handle the missing property and just return null. -- View this message in context: http://camel.465427.n5.nabble.com/Using-Camel-properties-tp5748299p5748353.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
Re: FOUND CAUSE! - FTP Move fails - have found cause but don't understands why
I did more debugging and found the cause
If you have streamDownload=true
Take a look at
org.apache.camel.component.file.remote.FtpOperations.retrieveFileToStreamInBody()
at line 345
if (endpoint.getConfiguration().isStreamDownload()) {
InputStream is = client.retrieveFileStream(remoteName);
target.setBody(is);
exchange.getIn().setHeader(RemoteFileComponent.REMOTE_FILE_INPUT_STREAM,
is);
result = true;
} else {
os = new ByteArrayOutputStream();
target.setBody(os);
result = client.retrieveFile(remoteName, os);
}
If you have streamDownload=true (the default is false) the FTPClient gets
into a different state than what FTPOperations expects. Then from that
point on, every time there is a call to FTPClient, the FTPClient is one
call behind what FTPOperations thinks it is and you get strange behavior.
I am hoping that this is enough info for the people that are knowledgeable
of this code to see the issue.
--
View this message in context:
http://camel.465427.n5.nabble.com/FTP-Move-fails-have-found-cause-but-don-t-understands-why-tp5748358p5748371.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel process the same file again when idempotent = true
Hi What do you mean by putting the same file in the folder? So if you have a file named foo.dat you have downloaded before. And you then override foo.dat with new content and want to pickup that file? For that see the idempotentKey option http://camel.apache.org/file2 On Thu, Mar 6, 2014 at 5:35 AM, spanchag sitaram.panchagn...@ericsson.com wrote: This is what my route looks like: camel:from uri=sftp://root:root123@10.61.150.7:22/root/ftp_location?stepwise=falseamp;idempotent=trueamp;binary=trueamp;delete=falseamp;stepwise=false; / .. .. When I put the same file in the folder, camel doesn't pick it up. Is there a way I can tell Camel to pick up the same file again even if idempotent=true. i.e I guess, Camel's LRU cache should be only 1. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-process-the-same-file-again-when-idempotent-true-tp5748373.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
