naming premove directory in cluster

2019-07-22 Thread arshad dar
i have Apache camel application running on multiple nodes. i want to name my premove direcoory on the basis node which is processing the file. is there any way to do this? e.g node1 picks file1 i want premove directory to be like this node1/file1 -- Arshid

change processor reference at run time

2019-07-28 Thread arshad dar
Hi i have a camel route like this from("direct:a").process(processorRef) i want to change the processor reference at run time. -- Arshid

combining hystrix and failover load balancer

2019-07-28 Thread arshad dar
i am trying to combine hystrix and failover load balancer, and this is what i have come up with so far hosturi={"netty-http:http://localhost:3000","netty-http:http://localhost:3001"} from("direct:a") .streamCaching() .loadBalance() .failover(maxAttempts, false,

distributing files among clusters

2019-08-02 Thread arshad dar
Hi All, i have few camel routes which are reading from a directory say Samples. the camel is running on multiple nodes and all systems are reading files from centralized location. my question how can i distribute files equally among all nodes. -- Arshid

Re: distributing files among clusters

2019-08-07 Thread arshad dar
> filenames to process, in a distributed way > > Regards > Laji > > > > On Fri, Aug 2, 2019 at 1:02 PM arshad dar wrote: > > > Hi All, > > > > i have few camel routes which are reading from a directory say Samples. > the > > camel is running on mul

increase number of requests with netty-http

2019-08-16 Thread arshad dar
Hi, i have route where i am reading file ,splitting with parallel processing and then passing it forward to rest api with netty-http. i am using camel default thread profile, and the performance i feel is not that good. i feel the bottle neck is netty-http. my undestanding of netty was it can han

batch http requests

2019-10-17 Thread arshad dar
in the routes below i am reading from file and sending http requests, one record for each http requests. what i want to do send multiple records in http request as an array. can any one help! thanks. from(fileURI) .to(dataformatURL) .split(body()) .streaming()

Re: batch http requests

2019-10-18 Thread arshad dar
gt; > Regards > JB > > On 18/10/2019 08:27, arshad dar wrote: > > in the routes below i am reading from file and sending http requests, one > > record for each http requests. what i want to do send multiple records in > > http request as an array. > &

netty-http over http

2019-10-23 Thread arshad dar
what is the advantage of using netty-http over http component i tried replacing one with other and i dont see any performance improvements. my understanding was netty can create very few threads and send multiple http requests over one thread. can any one help me in this regard? -- Arshid

improve performance of netty tcp

2019-11-17 Thread arshad dar
i have a netty tcp route which looks like this netty-route=netty4:tcp://localhost:82?allowDefaultCodec=false&encoder=#myByteArrayMessageEncoder&decoder=4#myEBCDICLengthDecoder&sync=true&clientMode=true&connectTimeout=1&correlationManager=#myMessageCorrelator&producerPoolEnabled=false i am s

Re: improve performance of netty tcp

2019-11-18 Thread arshad dar
On the client side I can see only one connection active at any given po3of time. Can I change this to multiple connections? On Mon, 18 Nov, 2019, 11:18 AM arshad dar, wrote: > i have a netty tcp route which looks like this > > > > netty-route=netty4:tcp://localhost:82?allowDef

marshal large file with flatpack

2019-12-22 Thread arshad dar
hi all i am trying to read a large file and marshal it with flatpack. i am using splitter pattern and streaming is enabled on route. when the file is large i am getting out of memory exception. is there any option to load data lazily as there is in csv format. -- Arshid

Pause the processing of file

2020-06-12 Thread arshad dar
I have two routes below, the first route processing a very large CSV file and the second one converts each record to JSON and forwards the message to http-route from(fileUri).routeId(mainRouteId).to(dataFormatURI).split(body()) .streaming() .to("direct:sample") from"direct:sample" .m

Re: Pause the processing of file

2020-06-12 Thread arshad dar
async and i can stop the second route. > > I am doing this very thing because my second route calls a third party > endpoint and it could be down. If it is down, i stop the processing. > > On Fri, Jun 12, 2020 at 4:41 AM arshad dar wrote: > > > I have two routes below, the f