Camel netty response handler

Hi i am trying to create a tcp sample with camel and started using camel-netty and it works great but i am not able to figure out how to handle responses . consider the following route client ---> from(netty:tcp://localhost:9[?options]).process(someprocessor)to(netty:tcp://remotehost:

camel netty timeout handler

Hi , I couldn't find 'timeout' option in the camel-netty component but it's available in camel-mina component .Has it been removed from netty?? I cant't use mina component as it won't support asynchronous model, can anyone suggest me how to implement timeout handler in netty component?? -

Activemq Request reply

Hi i m trying to implement request/response with jms but couln't succeed Here is my route from("netty:tcp://10.44.71.133:8003?textline=true&sync=false") .to("activemq:personnel.records")

Re: Activemq Request reply

Thanks claus I split the route into two routes. 1 - from("tcp").to("activemq"); 2 - from("activemq").process("processor").to("externaltcp"); It worked. - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/Activemq-Request-reply-tp5723817p5723830.

Serial communication

Hi Is there any camel component which can be used for serial communication?? Mina 2 supports serial communication so camel-mina2 component can be used ?? If yes where can I find the documentation regarding camel-mina2 component? - Regards kiran Reddy -- View this message in context: h

camel-netty restrict connections

Hi Is there any way we can restrict the number of clients that can connect the netty server ? For eg client 1 --->netty server client 2 >netty server the second connection should not be allowed while the first connection is active. Once the first connection is closed then second client

Re: camel-netty restrict connections

Hi What I meant is the second client should be denied by the server, I achieved this by checking the no of opened connections in 'channelOpen' method in 'ServerChannelHandler' and whenever a new connection opens I will just close that connection. I even added a new property to the 'NettyConfig

Re: Serial communication

Hi According to mina documentation it supports serial communication from 2.x.x version. Already camel has started camel-mina2 component based on mina 2.x.x , so m just eager to know whether it's already implemented in mina2 component or I have to build a custom component for this?? -

Re: camel-netty restrict connections

Hi Yeah I required these kind of server. I have done like as you said by maintaining the number of connection in a group. By checking the size of the group it decides whether to open a new connection or deny it. kindly check the code which i posted in the above post. - Regards kiran Red

Sclaing camel

Hi With spring and camel integration we have developed a webapp from which we can add or remove routes at runtime. Suppose if there is an tcp endpoint which is receiving some ten thousand requests is it advisable to run camel instance separately ?? or is it okay to run it in the web container it

Re: Sclaing camel

Thanks Christan it helped.. Consider this simple route async tcp(1) --->someBean(2) bean(2) will be accessing database for processing requests, What if the tcp endpoint gets 10k requests concurrently and bean(2) cant open that many database connections ?? Should i put the requests in queue

Re: Sclaing camel

Hi As camel running in the web container itself , it's performance won't be reduced?? Because it has to serve web requests also!! - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/Sclaing-camel-tp5724876p5725045.html Sent from the Camel - Users ma

activemq testConnectionOnStartup not working

Hi activemq's testConnectionOnStartup property is not working. And here is my route from("netty:tcp://localhost:8003?textline=true&sync=true") .to(ExchangePattern.InOut, "activemq:personnel.records?testConnectionOnStartup=true");

building response along with request data

Hi I have the following route from(netty:localhost).to(first processor).to(netty:external).to(second processor) Suppose a client has sent a request with some ten fields and after processing at first processor then it is sent to external host with only five fields and then to second processor.

Re: building response along with request data

Yeah but where can I can save the request message until it gets processed..?? And after saving how can co relate the request and response ?? - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/building-response-along-with-request-data-tp5727111p572726

building route in java dsl

Can anyone tell me how to build camel route dynamically in dsl. I am aware of recepientlist, dynamic router. Suppose I have a list of endpoint url's, how can i build route by iterating the list ?? List listOfEndpoints= In Route builder configure method can i define a single route

Building complex tcp route

Hi I am trying to simulate the existing tcp system with camel, This is the existing flow 1 2 3 4 5 client---> internalserver1 ---> requestHandler --->extrenalserver--->internalserver2--->requ

Re: Building complex tcp route

hi I have no control over the external server . I guess if i split the route into two routes it works. 1 from(internalserver1 ).process(server1requestHandler ).to(extrenalserver).process(responseHandler); 2 from(internalserver2).process(server2requestHandler ); External Server will be sendin

unable to start or stop activemq routes

Hi I'm unable to start or stop routes which has activemq as endpoint !! The start method blocks forever , What might be the reason??? - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/unable-to-start-or-stop-activemq-routes-tp5730896.html Sent fro

Activemq consumer is closing

Hi Consumer closes with the exception below ,could someone explain me what's causing this error? WARN Camel (camelcontext) thread #35 - TemporaryQueueReplyManager[connect.test] org.apache.camel.component.jms.reply.TemporaryQueueReplyManager - Exception inside the DMLC for Temporary ReplyTo Queu

Re: Activemq consumer is closing

Never mind, autoStart was set to false. - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/Activemq-consumer-is-closing-tp5731140p5731146.html Sent from the Camel - Users mailing list archive at Nabble.com.

cxf logging Feature Enabled to separate log file

Hi I am able to write cxf's inbound and outbound messages to log file with logFeatureEnabled. As of now these logs are written to my main app log file,but I need to write these inbound and outbound to separate file. Is there anyway I can mention appender name? - Regards kiran Reddy -- Vi

netty open close

Hi According to our use case we have built a route like this. from(jms).to(tcp netty).to(processor).to(tcp netty ) .to(processor).to(tcp netty ) Here all the tcp stations are same. Is it possible to make netty to use new connection at each tcp endpoint for every requset?? Because sometimes

Re: netty open close

Ya i tried that. But the problem is here all the tcp stations are same (Same Ip and port). So after disconnecting it's not trying to connect again. - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/netty-open-close-tp5733304p5733308.html Sent from

Re: netty open close

Tried that too.But still no luck. I guess its not even trying to open the connection again. - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/netty-open-close-tp5733304p5733313.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: netty open close

camel : 2.10.4 netty : netty-3.5.11.Final - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/netty-open-close-tp5733304p5733320.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: netty open close

As of now we are using these parameters , Still its not working. sync=true&lazyChannelCreation=false&producerPoolEnabled=false&disconnect=true - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/netty-open-close-tp5733304p5733326.html Sent from the Cam

Cxf MA SSL connectivity issue

Hi We are trying to connect a host system using MA SSL. Initial connection is happening properly and if we send ten transactions continiously everything is fine but when it is idle for 15 to 20 seconds we are getting ssl handshake error. handling exception: javax.net.ssl.SSLException: Received

Cxf MA SSL connectivity issue

Hi We are trying to connect a host system using MA SSL. Initial connection is happening properly and if we send ten transactions continiously everything is fine but when it is idle for 15 to 20 seconds we are getting ssl handshake error. handling exception: javax.net.ssl.SSLException: Received

Re: netty open close

Hi as per our observation we are getting ClosedChannelException when the remote machine is restarted. It's not trying to reconnect. - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/netty-open-close-tp5733304p5733364.html Sent from the Camel - Users

Re: netty open close

Without encoders and decoders of netty it is working as expected. Any alternate for the encoders and decoders?? - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/netty-open-close-tp5733304p5733372.html Sent from the Camel - Users mailing list archive

activemq replyTo not working sometimes

Hi We have following routes parent : from(CXF).to(JMS) child: from(JMS).to(processor) In jms endpoint we have set exclusive reply queue. Normally there is no issue, but sometimes if we are restarting the child route cxf is not receiving the replies and default time out exception is thrown.

Re: activemq replyTo not working sometimes

While restarting child route, Existing consumers are getting closed on the reply queue. And again it's not trying to reconnect!! - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/activemq-replyTo-not-working-sometimes-tp5733682p5733695.html Sent fro

Re: activemq replyTo not working sometimes

Hi We have created a web app to create camel stations(endpoints) and routes dynamically. So users can add new stations and then create routes based on that stations. For one of our use case we need to create a web service with different operations. So we decided to use cxf ,content Router and JM

camel netty deadlock

Hi I m getting the following exception when trying to use more than two netty endpoints in a single route. java.lang.IllegalStateException: await*() in I/O thread causes a dead lock or sudden performance drop. Use addListener() instead or call await*() from a different thread. Sample route :

scaling camel netty

Hi Could anyone help me in scaling camel netty, Here are my routes First from("netty:tcp://localhost:7000?textline=true") .bean(LoggingProcessor.class) .to("netty:tcp://localhost:7001?textline=true") .bean(LoggingProcessor.class) .to("netty:tcp://localhost:7002?textline=true") .bean(LoggingProc

Re: camel netty deadlock

Hi Tested the 2.12-SNAPSHOT and it works. So closed this ticket too https://issues.apache.org/jira/browse/CAMEL-6449 - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/camel-netty-deadlock-tp57340

Re: Activemq consumer is closing

Hi We have created activemq consumer with property autostartup = false. So the queue wasn't created and it while it was trying to write to the queue (which doesn't exist) we got that exception. Once we changed that autostartup = true , it was fine. - Regards kiran Reddy -- View this mes

Re: Activemq consumer is closing

can U try setting "replyToType"=Exclusive and "replyTo"=anyqueue - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/Activemq-consumer-is-closing-tp5731140p5734366.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Activemq consumer is closing

Hi I got this warning while using temporary reply queues. But once I moved to exclusive reply queues it's fine. camel version : 2.10.3 activemq : 5.7.0 - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/Activemq-consumer-is-closing-tp5731140p5734388

Re: Activemq consumer is closing

And it was not working because of autoStartup=false. As you said it's just a warning. - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/Activemq-consumer-is-closing-tp5731140p5734389.html Sent from the Camel - Users mailing list archive at Nabble.

camel - Activemq performance suggestions

Hi, Can anyone suggest any performance improvement techniques for camel-activemq We have tried connection pooling mentioned in this page http://camel.apache.org/activemq.html Here is my xml and route configuration from("netty:tcp://10.44.71.187:7000?te

Re: camel - Activemq performance suggestions

Hi Without activemq in the sense direct tcp to tcp. No other queue in the middle. from("netty:tcp://10.44.71.187:7000?textline=true").threads(800,800) .bean(MainDummyProcessor.class) .to("netty:tcp://10.44.71.67:7004?textline=true"); - Regards kiran Reddy -- View t

Re: camel - Activemq performance suggestions

Ya I agree jms will add little overhead, But based on the results I got TCP is 10x faster. Generally will there be this much difference?? - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/camel-Activemq-performance-suggestions-tp5734508p5734539.html S

Re: camel - Activemq performance suggestions

Hi, We should not use threads options at all or we should have some limited number of threads on netty?? And in my xml configuration i have already given concurrentConsumers as 100. So on reply queue also i can see 100 consumers are listening by the abov

Re: camel - Activemq performance suggestions

Hi , By using the following property 'useAsyncSend' activemq performance has been improved. - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/camel-Activemq-performance-suggestions-tp5734508p5734637.html Sent from the Camel - Users mailing list ar

netty thread pool clarification

Hi , Can anyone suggest how to improve performance of netty without using additional thread pool. As mentioned here that we should not use additional threads http://camel.465427.n5.nabble.com/camel-Activemq-performance-suggestions-td5734508.html Consider this simple route from("netty:tcp://local

Re: netty thread pool clarification

Hi, Thanks for quick reply. And generally on a netty consumer is it okay to use additional thread pool or default thread pool is enough ? If default pool is enough what is it's pool size and how can I increase it? - Regards kiran Reddy -- View this message in context: http://camel.465427

Re: netty thread pool clarification

Hi , I was trying to simulate normal bussiness logic like checking ,inserting or updating to database. Assuming these steps take 100 ms, So instead of writing the logic I have kept sleep(100). Anyway thanks for your explanation. - Regards kiran Reddy -- View this message in context: h

logging multiple instances

hi I would like what is the best approach for logging multiple instances to single file ? As of now I'm thinking to send all logs as message to jms endpoint and create one separate instance for logging alone ,which will be listening on jms and then writes to file. - Regards kiran Reddy

Re: logging multiple instances

Or is it better to use JMSAppender or SocketAppender of log4j ? - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/logging-multiple-instances-tp5734873p5734905.html Sent from the Camel - Users mailing list archive at Nabble.com.

java.net.BindException: Address already in use

Hi When performing load testing on the following route some of the requests are failing with this exception Route : from("cxf:bean:orderEndpoint").bean(CXFRequestProcessor.class) .to("netty:tcp://10.44.71.101:7001textline=true").to("netty:tcp://10.44.71.67:7004textline=true") .bean(MainDummyPro

Re: java.net.BindException: Address already in use

Hi I m running only one test instance. Anyway i got exception while processing request, i.e while sending to external tcp host . - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/java-net-BindException-Address-already-in-use-tp5735132p5735141.html S

Re: java.net.BindException: Address already in use

cxfloadtest.csv It is available ,because very few transactions (1 %) are failing . Please find the load test details in the attached file. - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.na

Re: java.net.BindException: Address already in use

By error handler solved the above issue, onException(BindException.class).handled(true).maximumRedeliveries(3).redeliveryDelay(1000).asyncDelayedRedelivery(); But not sure why it's causing though. - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/

org.apache.camel.CamelException: Cannot connect to

Hi , while performing load testing on the following route I am getting these error for *some *messages from("netty:tcp://0.0.0.0:7000?textline=true") .bean(MainDummyProcessor.class) .to("netty:tcp://0.0.0.0:7001?textline=true").to("netty:tcp://0.0.0.0:7004?textline=true") .bean(MainDummyProcessor

Re: org.apache.camel.CamelException: Cannot connect to

Hi, As mentioned earlier only some of the requests (1%) are failing with the above exception, remaining all are processing successfully. - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/org-apache-camel-CamelException-Cannot-connect-to-tp5735414p

camel rabbitmq

Hi I tried to use camel-rabbitmq component from 2.12 snapshot. Here is my route. from("netty:tcp://0.0.0.0:7000?textline=true").to("rabbitmq://localhost/A?routingKey=B&username=guest&password=guest"); And I am getting null pointer exception. Here is full stacktrace Stacktrace -

camel - Activemq strange behaviour

Hi I'm trying to implement camel-activemq. Here is the route : from("netty:tcp://0.0.0.0:7000?textline=true") .bean(MainProcessor.class) .to("activemq:CAMEL_ONE_QUEUE?testConnectionOnStartup=true&replyTo=CAMEL_ONE_QUEUE_REP&replyT

Re: camel - Activemq strange behaviour

Thanks Is this the way to set prefetch limit destination.consumer.prefetchSize=1 ? And it has to be set on producer only right ? - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/camel-Activemq-strange-behaviour-tp5736812p5736820.html Sent from th

Re: camel - Activemq strange behaviour

hi I tried setting prefetch limit to 1 , but still of no use. And according to link you have given , at least the first server's consumers should get the message right ?? No one is picking up the messages and timeout is happening. - Regards kiran Reddy -- View this message in context

Re: camel - Activemq strange behaviour

Hi I think I figure out the problem. Here is the scenario, 1 Start producers and consumers in server 1. 2 Send requests to first server, everything will be processed. 3 Start producers and consumers in server 2. 4 Send requests to first server, everything will be processed. But if we send r

Re: camel - Activemq strange behaviour

Hi Thanks a lot. So we should have unique queue names in cluster environment, if we are using replyToType as exclusive or temporary queues can be used. - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/camel-Activemq-strange-behaviour-tp5736812p57

camel threshold

Hi How can we find out the threshold for any camel route ? I mean how to find the maximum number of messages a particular route can process and it can't take any more messages. I came across camel throttle , if the threshold is reached the new messages will be saved somewhere for processing ?

Re: camel threshold

Hi consider this simple route from("netty:tcp://0.0.0.0:7004?textline=true").throttle(100).to("netty:tcp://0.0.0.0:7005?textline=true"); According to this only 100 requests per second will be sent to second endpoint. Assume that first endpoint is receiving some thousand messages per second, h

Re: camel threshold

Hi Thanks for reply. One more clarification There is request time out option in netty right , For handing time outs also any in-memory queue will be used ? Because there may be chances we get memory issues when external sever is not at all replying . - Regards kiran Reddy -- View t

camel routes suspend /resume

Hi Netty is still accepting new connections and new message even though it is suspended. I'm able to suspend and resume routes by jmx via jconsole. When I'm suspending second route it's working correctly, i.e it stopped processing messages. Where as if I'm suspending first route netty is still

Re: camel threshold

hi Any update regarding netty request time out? - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/camel-threshold-tp5737136p5737383.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: camel routes suspend /resume

Hi, So the following route policy cannot be used? org.apache.camel.impl.ThrottlingInflightRoutePolicy - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/camel-routes-suspend-resume-tp5737382p5737407.html Sent from the Camel - Users mailing list archi

Camel service start/stop

Hi i would like to know how to use the following class http://camel.apache.org/maven/current/camel-core/apidocs/org/apache/camel/support/ServiceSupport.html how can I make my custom class so that it is managed by camel ?? - Regards kiran Reddy -- View this message in context: http://came

Re: Camel service start/stop

Hi I have created a class by extending ServiceSupport. And I'm staring my program with the following code. public static void main(String... args) throws Exception { AbstractApplicationContext applicationContext = new ClassPathXmlApplicationContext( "cla

camel akka use cases

Hi Has anyone used camel-akka component ? For what type of use cases it will be helpful? And how is it different from camel/processor to camel/actor model? - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/camel-akka-use-cases-tp5738388.html Sent

running hawtio in standalone camel app

Hi How to run http://hawt.io/ hawtio in standalone camel app? I tried this io.hawt.embedded.Main hawtioMain=new io.hawt.embedded.Main(); hawtioMain.setContextPath("/hawtio"); hawtioMain.setPort(8000); hawtioMain.setWar("D:

Re: running hawtio in standalone camel app

Thanks - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/running-hawtio-in-standalone-camel-app-tp5738579p5738588.html Sent from the Camel - Users mailing list archive at Nabble.com.

camel exception - netty

Hi While using camel-netty we have noticed that when remote sever is down netty component is throwing org.apache.camel.CamelException. It should be throwing java.net.ConnectException right?? So that it will be easy for error handling. - Regards kiran Reddy -- View this message in cont

Re: camel exception - netty

camel version : 2.12.1 Stacktrace : INFO 08 Nov 2013 15:20:08,767 org.apache.camel.main.MainSupport - Apache Camel 2.12.1 starting INFO 08 Nov 2013 15:20:09,001 org.apache.camel.impl.DefaultCamelContext - Apache Camel 2.12.1 (CamelContext: camel-1) is starting INFO 08 Nov 2013 15:20:09,001 org.apa

Re: camel exception - netty

Thanks - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/camel-exception-netty-tp5742647p5742839.html Sent from the Camel - Users mailing list archive at Nabble.com.

Producer template error handling

Hi I would like to know how to do error handling with producer template. I'm sending a message to activemq endpoint using 'requestBody' of producer template. Suppose if there is requestTimeout in activemq how can I catch that exception and build response?? - Regards kiran Reddy -- Vie

Re: Producer template error handling

Hi Ya I was asking about timeout. Thanks - Regards kiran Reddy -- View this message in context: http://camel.465427.n5.nabble.com/Producer-template-error-handling-tp5743684p5743735.html Sent from the Camel - Users mailing list archive at Nabble.com.