Re: Slow FTP

2015-03-16 Thread Willem Jiang
Can you try to setup the FtpClient with a big buffer just like this ? from(ftp://foo@myserver?password=secretftpClient.bufferSize=1000;).to(bean:foo); -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese)

Re: Concurrent Consumers creating duplicates

2015-03-16 Thread Willem Jiang
The route looks good to me. Can you double check the JMS acknowledge setting of JMS connection? -- 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 16, 2015

Re: Names of custom MBeans contain hex-number at the end

2015-03-16 Thread Willem Jiang
The hex-number is the instanceId to avoid the name conflict.  If you want to get ride of it, you need to make sure the service is a StaticService which means you have only one instance per Camel Context. You can find the below code in the DefaultManagementNamingStrategy. public ObjectName

RE: how to send response to the webservice

2015-03-16 Thread chaituu
thanks for all replies. as all you said we can resolve this issue by using any of one of these following patterns. 1)wireTap uri=seda:generateCSV/ 2)inOnly uri=seda:generateCSV/ 3)to uri=seda:generateCSV pattern=inOnly/ -- View this message in context:

Re: Dynamic Splitter timeouts

2015-03-16 Thread Claus Ibsen
There is no support for dynamic timeout values. On Mon, Mar 16, 2015 at 7:38 AM, Gnanaguru S gnanagu...@gmail.com wrote: Hi All, I have a use case where, the requests will have a timeout value. Based on this timeout value Splitter should timeout. Splitter processor has the option of

Re: Sql component lazy loading?

2015-03-16 Thread angelo.rlcosta
Hi Claus, Every time i try access ${body[0]} to get the first item returned from the list from the DB seems a bit slow. Seems like lazy loading is enabled. Therefore wanted to try use lazy loading = false somehow to check if its faster. -- View this message in context:

Re: Cacehe-Controle header

2015-03-16 Thread richardgroote
Hello, We used the below header strategy on the servlet component to allow some headers. public class ParameterizedHttpHeaderFilterStrategy extends DefaultHeaderFilterStrategy { private final String[] allowedOutHeaders; public ParameterizedHttpHeaderFilterStrategy(String

Slow FTP

2015-03-16 Thread ulsa
One of the files on my FTP server is ~200MB. I'm using Camel FTP from an EC2 instance (Ubuntu 14), and I get a connection reset error on that file after 25 minutes. However, when using command line ftp on the same machine, the same file takes 38 seconds to download. I have set option

Re: Cacehe-Controle header

2015-03-16 Thread Claus Ibsen
No I dont think so. But maybe we should think about making that easier to configure on servlet / jetty and HTTP server like components. On Thu, Mar 12, 2015 at 4:17 PM, richardgroote richard.gro...@gmail.com wrote: Hello, For https://issues.apache.org/jira/browse/CAMEL-1975 a lot of headers

Sql component lazy loading?

2015-03-16 Thread angelo.rlcosta
Hi guys, does anyone know if sql component has an option to disable lazy loading? -- View this message in context: http://camel.465427.n5.nabble.com/Sql-component-lazy-loading-tp5764211.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Sql component lazy loading?

2015-03-16 Thread Claus Ibsen
Hi What do you mean by lazy loading? On Mon, Mar 16, 2015 at 12:01 PM, angelo.rlcosta angelo.rlco...@gmail.com wrote: Hi guys, does anyone know if sql component has an option to disable lazy loading? -- View this message in context:

Re: Bean invocation .class vs new

2015-03-16 Thread yuncil
Hey Claus, thank you I got it now. -- View this message in context: http://camel.465427.n5.nabble.com/Bean-invocation-class-vs-new-tp5764039p5764217.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Concurrent Consumers creating duplicates

2015-03-16 Thread kishore
Here is the WMQRouter. The Ack queue is for a different purpose. we have to change the message adding some more data and send the Ack back. /public class WMQRouter extends RouteBuilder { public static org.apache.log4j.Logger LOG =

Re: CXF-RS get but no response

2015-03-16 Thread Sergey Beryozkin
As far as I recall you can not use a cxfrs bean with a from, one can delegate to it with a from:jetty, etc... I believe you need to drop a 'bean' part... AFAIK The bean component is useful if you need to invoke on a JAX-RS service implementation. You can do it in Camel 2.15.0 directly with a

AW: Dynamic Splitter timeouts

2015-03-16 Thread jhm
My idea was - adding an 'id' to the splitter - later on during runtime (e.g. on an event) get that splitter instance by its id and modify its timeout value. Tried using JavaDSL, but with Camel 2.15.0 I havent any timeout method found ... Jan -Ursprüngliche Nachricht- Von: Claus

Dynamic MBeans/ dynamically create MBeans in Camel

2015-03-16 Thread dermoritz
Thanks to this mailing list i know how to create custom mbeans by implementing Service and adding them to CamelContext. But is there also such an easy way to create/add dynamic MBeans and or dynamically create Mbeans - Attributes/Operation and or MBeans are defined on Runtime? In my case i read

Names of custom MBeans contain hex-number at the end

2015-03-16 Thread dermoritz
I created some custom MBeans (implementing Service). they work as they should but for some reason their names have some hexadecimal number at the end e.g. JmxController (0x32e652b6). Is there a way to get rid of this number? What does this number mean - only my custom Services have such a number?

Java DSL kick-starting routes, is this possible yet?

2015-03-16 Thread mikes300
I can kick-start a route (for example by a file or message/q or timer input) automatically in Spring and read in a couple posts that doing this via a pure Java DSL implementation was possible but still find no evidence of it. Is this possible yet does anyone know? Or if anyone has gotten

Possibility of jdbc component when performing a select to return a map

2015-03-16 Thread angelo.rlcosta
HI Guys, i'm using jdbc component to perform a selectList. I've noticed that according to the impl it returns a ListMaplt;String, Object data = extractResultSetData(rs); Is there any type of transformation i can perform to have data like MapString, Maplt;String, Object so instead of a List i

Re: Possibility of jdbc component when performing a select to return a map

2015-03-16 Thread Antoine DESSAIGNE
Hi, No, it's not possible. In order to be unique in your Map it has to know which fields are part of key (assuming that you retrieve them all). If you have camel-groovy in your project you can do the following: to(jdbc:something).setBody(new GroovyExpression(request.body.collectEntries

Re: Java DSL kick-starting routes, is this possible yet?

2015-03-16 Thread yogu13
https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=examples/camel-example-jms-file/src/main/java/org/apache/camel/example/jmstofile/CamelJmsToFileExample.java;h=bf0c708d9a67f7bc5c7a6e2f1e17a90ca7821c01;hb=HEAD Hope this helps! Regards, -Yogesh -- View this message in context:

Re: Slow FTP

2015-03-16 Thread yogu13
Hello, Which version of Apache Camel is being used along with the JDK version. Regards, -Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/Slow-FTP-tp5764223p5764240.html Sent from the Camel - Users mailing list archive at Nabble.com.

CVE-2015-0263 and CVE-2015-0264 - Apache Camel medium disclosure vulnerability

2015-03-16 Thread Christian Mueller
If you are using Apache Camel to route XML messages, please note that the security advisories CVE-2015-0263 and CVE-2015-0264 may affect you. Please study these critical security vulnerability carefully! CVE-2015-0263 [1] CVE-2015-0264 [2] You can download the fixed Apache Camel 2.13.x and

Re: how to know how many files Camel Endpoint scanned?

2015-03-16 Thread Nazarii Kukhar
Hi, Take a look at this SO question http://stackoverflow.com/questions/26972590/camel-count-number-of-files-got-routed-or-consumed, looks like exactly what you are looking for. On Fri, Mar 13, 2015 at 11:08 AM, ramanarao vjyothi.n...@gmail.com wrote: I have endpoint which scans the

Dynamic Splitter timeouts

2015-03-16 Thread Gnanaguru S
Hi All, I have a use case where, the requests will have a timeout value. Based on this timeout value Splitter should timeout. Splitter processor has the option of timeout, but I doubt whether we can pass dynamic value to that. split strategyRef=aggregationStrategy

Re: Concurrent Consumers creating duplicates

2015-03-16 Thread kishore
Here is my camel-context.xml file ?xml version=1.0 encoding=UTF-8? beans xmlns=http://www.springframework.org/schema/beans; xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance; xmlns:context=http://www.springframework.org/schema/context;

Camel route - autostartup - no endpoint found

2015-03-16 Thread ychawla
Hello All, I have a route with autoStartup set to 'false'. However, Camel will still try to resolve the endpoint in the 'from' URI on the route. For example: camel:route id=myRoute autoStartup=false from uri=myCXFServiceEndpoint/ However, I don't have

Re: Camel route - autostartup - no endpoint found

2015-03-16 Thread ychawla
I tried injecting a Camel Context into the Route Policy, but it looks like the route isn't yet created so it can't be deleted: @Override protected void doStart() throws Exception { LOG.info(In custom do start); boolean removed =

Manipulate messages for aggregator when there is no message ready to aggregate

2015-03-16 Thread Gnanaguru S
Hi, Lets say I have a splitter which splits a large message into 10 messages and sends each message to a CXF Web service endpoint. Assume only 7 message are responded and 3 messages are still in progress. 1. I dont want to wait, I want to aggregate 7 successful messages + 3 manipulated

Re: Quartz Component quartz.properties in Karaf

2015-03-16 Thread Willem Jiang
I think you can put the quartz.properties file into your application bundle or karaf etc directory. You can specify quartz.properties file with relative path or absolute path (if you like) by calling QuartzComponent.setPropertiesFile() method just like this context.getComponent(quartz,

Re: Concurrent Consumers creating duplicates

2015-03-16 Thread Willem Jiang
I didn’t find the Route definition of wmqRoute, you may need to show us the code of  com.broadridge.adapters.fixadapter.router.WMQRouter. BWT, why do your route need to specify the “ackQueue”? -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com