Re: Large Number of threads getting spawned in File Producer

Hi, I'd be surprised if a thread was started for every file. By default the file consumer is using a thread pool of size 1. Anyway you can customize this by specifying a ScheduledExecutorService on the endpoint (e.g. ftp://.&scheduledExecutorService=#myExecutorService) where myExecutorService

Re: disabeling loadStatistics

Found some time to dig into this. Figured out that I explicitly have to set the createConnector on the jmxAgent to 'false' then it works. The documentation says this should be the default value, but it seems not to b

Re: disabeling loadStatistics

Hi Yeah that should have been false, as it is in camel-core. Feel free to log a JIRA. On Wed, Feb 5, 2014 at 10:05 AM, Preben.Asmussen wrote: > Found some time to dig into this. > > Figured out that I explicitly have to set the createConnector on the > jmxAgent to 'false' then it works. > > The

Re: Large Number of threads getting spawned in File Producer

Hi Claus, My route is running in a Storm cluster. And all I do in my processor is call a listener to emit the File name and the produced file path to the Spout which passes it on to the Bolts. The thread name which I can see in my Profiler is "file:///destination_dir" which gives an impression

Re: Large Number of threads getting spawned in File Producer

Hi Richard, Its not the FTP Consumer threads. I can see in my Profiler,a single threaded FTP Consumer. Its the File Producer which has an increasing number of threads. Can I somehow configure a thread pool for the File Producer? Thanks a lot! Chirag From:

Re: disabeling loadStatistics

created https://issues.apache.org/jira/browse/CAMEL-7173 -- View this message in context: http://camel.465427.n5.nabble.com/disabeling-loadStatistics-tp5746709p5746830.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Large Number of threads getting spawned in File Producer

Hi Its maybe storm then. All threads created by Camel is prefixed with Camel by default. There is a naming syntax you can configure http://camel.apache.org/threading-model.html On Wed, Feb 5, 2014 at 10:49 AM, Chirag Dewan wrote: > Hi Claus, > > My route is running in a Storm cluster. And all

java.lang.ClassCastException: java.util.ArrayList$Itr cannot be cast to org.apache.avro.generic.IndexedRecord

Hi all, (I sent this originally to the avro list, but it was suggested that I try here instead/as well) after many experiments of using camel-avro, I decided to send an email to the list as I'm getting ClassCastException errors, even with simple schemas. Java class from AVRO Schema file (avsc)

Invoking route inside processor

Hi all, I have to deal with a large data set in middle of my route. I am trying to process it in parts using a SEDA route with many concurrent consumer. Is there any way I can put message to a route inside a loop in my custom processor component or a bean component? Please advice. -- BR Muhsin

Re: Invoking route inside processor

Yes using a producer template, or pojo producing. Search the web site for these keywords and find the links. On Wed, Feb 5, 2014 at 12:22 PM, Muhzin wrote: > Hi all, > > I have to deal with a large data set in middle of my route. I am trying to > process it in parts using a SEDA route with many c

Re: Invoking route inside processor

Hi Muhzin To add to what Claus said... I just happened to have some similar code in front of me... Your processor overrides "process" which gets an "Exchange". >From the Exchange you can do exchange.getContext.createProducerTemplate().sendBody("some uri", "some message") Check out the API for de

Re: Invoking route inside processor

Hi Just note the FAQ[1] before creating ProducerTemplate inside a processor, rather inject/create a single instance on startup. [1] http://camel.apache.org/why-does-camel-use-too-many-threads-with-producertemplate.html On Wed, Feb 5, 2014 at 2:02 PM, Alvaro Rodriguez wrote: > Hi Muhzin > > To

Init a route but preserve its consumer in stopped state

Hello allI've faced an issue with no possible way to init a route (warm it up) but preserve its consumer in stopped state.It turned out that in Camel 2.10, Route instance passed to RoutePolicy#onInit(Route route) is not yet initialized, so does not have consumer assigned (route.getConsumer() == nul

FTP Producer: Filename Header using SimpleLanguage

Hi @ll, we have a route simplified as following: from("direct:export") .process(new DataProcessor()) .setHeader("timestamp", constant(myDate)) .setHeader(Exchange.FILENAME, constant("ID_${date:header.timestamp:MMddHHmm}_mdata.xml")) .to("ftp://ftpserver/";)

Re: FTP Producer: Filename Header using SimpleLanguage

Hi You should use simple instead of constant On Wed, Feb 5, 2014 at 4:36 PM, wrote: > Hi @ll, > > we have a route simplified as following: > > from("direct:export") > .process(new DataProcessor()) > .setHeader("timestamp", constant(myDate)) > .setHeader(Exchange.FILENAM

AW: FTP Producer: Filename Header using SimpleLanguage

Hi Claus, Thanks for your help, the header is produced in a processor via Java before to is invoked: String filename = "ID_${date:header.timestamp:MMddHHmm}_mdata.xml"; exchange.getIn().setHeader(Exchange.FILE_NAME, filename); changing it to exchange.getIn().setHeader(Exchange.FILE_NAME, new

Can I use a Servlet 3.0 Web.xml with camel-servletlistener 2.12.1

Greetings, We are using servletlistener to bootstrap camel into a web app deployed on JBoss EAP 6.2 and I was wondering if I could use a servlet 3.0 spec web.xml with the servletlistener even though the listener is only compiled against geronimo 2.5 spec? Thanks in advance. *Robert Simmons Jr. M

Re: Can I use a Servlet 3.0 Web.xml with camel-servletlistener 2.12.1

Give it a try and let us know. On Wed, Feb 5, 2014 at 5:01 PM, kraythe . wrote: > Greetings, > > We are using servletlistener to bootstrap camel into a web app deployed on > JBoss EAP 6.2 and I was wondering if I could use a servlet 3.0 spec web.xml > with the servletlistener even though the list

Not getting out of Processor

Hi, I wrote a custom processor which consumes a message from amazon sqs. When run, the processor is not getting out of the processor. In the processor, there is a read to amazon dynamodb. It keeps on consuming the same message and is stuck there. Please help. from(sqsQueue) .u

Camel - SFTP rename problems.

Hi - i have a requirement to consume the file from remote server using sftp and rename the consumed file at same location in remote server. suppose my remote file name = "REMOTEFILE.TXT' to be renamed to = "${date:now}_PROCESSED.TXT" I am trying with the below end point - i know which is not cor

Sometimes HttpResponse close too early

Hi, I am using Camel 2.11. I have a Camel endpoint that uses jetty:http to listen to http request The http requests are routed to a processor and after some processing, a pixel is sentback to the client, via Http Response. AbstractJSCollector.java : public void setResponse(HttpServletResp

Re: Posting a file to a web service

Update: Once I added the camel-jetty component to my apache-servicemix configuration my SSL woes cleared up. My new issue pertains to formatting my PUT request in a way that the web service can interpret, because right now they are not getting anything of value. As stated before, the curl st

AW: Camel - SFTP rename problems.

Hi Jay, the move option will always move the file into a subdirectory and will not rename the file. If you want to rename the file, I think, you can do it with the ssh endpoint. ftp://user@remoteserver:22//opt/data/somedir?password=somepassword&localWorkDirectory=/tmp"; /> . mv /

GuiceCamelContext checked exception issue with Glassfish4

I am trying to run my application in Glassfish 4 and I am getting the error below which is due to Exception being thrown in the @PostContruct method. According to the J2EE spec methods with the @PostConstruct annotation "MUST NOT throw a checked exception". Does anyone have a good work around for

JBOSS FUSE WEBCONSOLE ISSUE

Hi all, I am running my fuse web console in IE 10. Am getting HTTP 405 error when I am Clicking "Apply Filter " button in the web console. And "Install/Bundle" button is also not working , ie the dialogue box for "upload/install" is not coming.What could be the possible reason for this? Is it be

JBOSS FUSE WEBCONSOLE ISSUE

Hi all, I am running my fuse web console in IE 10. Am getting HTTP 405 error when I am Clicking "Apply Filter " button in the web console. And "Install/Bundle" button is also not working , ie the dialogue box for "upload/install" is not coming.What could be the possible reason for this? Is it

Re: JBOSS FUSE WEBCONSOLE ISSUE

Hi This is the WRONG forum to ask questions about JBoss Fuse. You can find link to their user discussion forum from their web site at http://www.jboss.org/products/fuse On Thu, Feb 6, 2014 at 6:52 AM, vs_mahesh wrote: > > Hi all, > > I am running my fuse web console in IE 10. > Am getting HTT

Re: GuiceCamelContext checked exception issue with Glassfish4

What Camel version do you use? And have you tried with latest release? On Thu, Feb 6, 2014 at 12:26 AM, brianorwig wrote: > I am trying to run my application in Glassfish 4 and I am getting the error > below which is due to Exception being thrown in the @PostContruct method. > According to the J2