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)
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
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
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:
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
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:
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
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
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
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.
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:
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.
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 =
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
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
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
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?
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
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
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
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:
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.
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
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
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
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;
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
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 =
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
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,
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
31 matches
Mail list logo