AsyncProcessor implementation patterns

Hi, I want to implement a custom AsyncProcessor so I can have more control on a custom Netty channel. Is the following pattern recommended? @Override public boolean process(Exchange exchange, AsyncCallback callback) { try { //Do whatever sync prepar

Camel and Sockets

Is it possible to treat a single socket like two different routes (inbound and outbound)? I want to handle the messages independently, asynchronously and with correlation ids. Thanks. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-and-Sockets-tp5739687.html Sent from

Re: Concurrency problem with Netty and producerPoolEnabled=false

Just to be clear, the original problem remains. What was wrong was the "extension" of the problem. -- View this message in context: http://camel.465427.n5.nabble.com/Concurrency-problem-with-Netty-and-producerPoolEnabled-false-tp5739679p5739683.html Sent from the Camel - Users mailing list arch

Re: Concurrency problem with Netty and producerPoolEnabled=false

I continued looking at the code and I realized I was wrong. When using a pool, channel is returned to the pool when response is received and processed. So that case works ok. -- View this message in context: http://camel.465427.n5.nabble.com/Concurrency-problem-with-Netty-and-producerPoolEnable

Concurrency problem with Netty and producerPoolEnabled=false

Hi, If producerPoolEnabled=false and there are two concurrent requests, the netty producer doesn't know which response is from what request and it assumes both responses are from the last request sent. This is because when producerPoolEnabled is false, the channel is used concurrenty, as opposed t

Re: DefaultErrorHandler and "nested" routes

Hi, I cannot use a global onException because different actions have to be taken on different routes to handle the exceptions. Besides, I'm handling NoSuchElementException which is a very generic exception and handling should be restricted to a specific route. Just to be sure, OnException never h

DefaultErrorHandler and "nested" routes

Hi, I have these routes: from("direct:a").routeId("1") .onException(Exception.class).handled(true).to("direct:d").end() .to("direct:b").to("direct:c"); from("direct:b").routeId("2").process(new ThrowingExceptionProcessor()); from("direct:c").routeId("3").process(new OkProcessor()); from("direct

Re: Netty and requestTimeout

As a workaround, I implemented a handler which modifies the pipeline on every request so the ReadTimeoutHandler is removed once the response is read. Specifically, a CamelRequestTimeoutHandler is inserted before Camel's ClientChannelHandler. My handler inserts a ReadTimeoutHandler on write and remo

Re: Netty and requestTimeout

Sorry, I forgot to mention I'm using 2.11.1 -- View this message in context: http://camel.465427.n5.nabble.com/Netty-and-requestTimeout-tp5738341p5738534.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Netty and requestTimeout

Hi, This test reproduces the exception. The System.in.read() at the end is just to wait for the exception to appear. Any ideas? Thanks. package camel.test; import java.io.IOException; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.test.junit4.CamelTestSupport; import org

Camel, Netty, and IdleStateHandler

Hi, I want to send echo messages when channels are idle. However, I don't know how this feature fits nicely with Camel channel pool. How can I tell camel not to use some channels while I'm sending an echo message? Is it possible? I was thinking to implement a handler which locks the channel, but t

Re: Netty and requestTimeout

I forgot to mention I'm using persistent connections with this producer. -- View this message in context: http://camel.465427.n5.nabble.com/Netty-and-requestTimeout-tp5738341p5738342.html Sent from the Camel - Users mailing list archive at Nabble.com.

Netty and requestTimeout

Hi, I'm having problems with requestTimeout on a Netty component. A NullPointerException raises when camel tries to get UnitOfWork. It looks like the timeout is raising even though there is no current inflight exchange. Any ideas? Thanks. An exception was thrown by a user handler while handling a

Re: Truststore in HTTP4 component not working

I must add it looks like there are two instances of HttpComponent. One is configured with SSL context and the other is not. Is that ok? -- View this message in context: http://camel.465427.n5.nabble.com/Truststore-in-HTTP4-component-not-working-tp5731925p5731926.html Sent from the Camel - Users

Truststore in HTTP4 component not working

I use the following code: KeyStoreParameters ksp = new KeyStoreParameters(); ksp.setResource("truststore_test.jks"); ksp.setPassword("password"); TrustManagersParameters trustManagersParameters = new TrustManagersParameters(); trustManagersParameters.setKeyStore(ksp); SSLContextParameters scp =

User agent header on HTTP component

Hi, How can I set user-agent header on http component? Thanks. -- View this message in context: http://camel.465427.n5.nabble.com/User-agent-header-on-HTTP-component-tp5731761.html Sent from the Camel - Users mailing list archive at Nabble.com.

Log sent messages

In a Request-Reply context, I want to log an outgoing message after it is sent. I could do something like: from("direct:start").to("netty:tcp:...).to("log:logSent?showAll=true&multiline=true") But I would be logging the response. On the other hand, if the route is like this: from("direct:start")

Re: consumer.bridgeErrorHandler=true on netty uri

Hi Claus, It's 2.10.4. In case it does not work, how can I set a custom exception handler to the netty consumer? Thanks. -- View this message in context: http://camel.465427.n5.nabble.com/consumer-bridgeErrorHandler-true-on-netty-uri-tp5731038p5731163.html Sent from the Camel - Users mailin

Re: How to set a custom ExceptionHandler to a consumer

Hi Valerian, I was talking about org.apache.camel.spi.ExceptionHandler. As far as I know, OnException does not catch exceptions thrown inside the consumer such as java.nio.channels.ClosedChannelException. Any ideas? Thanks. -- View this message in context: http://camel.465427.n5.nabble.com

How to set a custom ExceptionHandler to a consumer

Hi, I have a route definition like this: from("netty:tcp:...").transform(constant("hello")); How can I set a custom ExceptionHandler to the netty consumer created from that route? Thanks. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-set-a-custom-ExceptionHandler

Re: consumer.bridgeErrorHandler=true on netty uri

Ok, I guess it's not supported then. I find it by looking the source. As I said, NettyConsumer extends DefaultConsumer and DefaultConsumer has that feature. -- View this message in context: http://camel.465427.n5.nabble.com/consumer-bridgeErrorHandler-true-on-netty-uri-tp5731038p5731095.html Se

Re: Bindy fixed length

I tried it but I couldn't make it work. It says @Link is for @CsvRecord. Should it work on @FixedLengthRecord too? -- View this message in context: http://camel.465427.n5.nabble.com/Bindy-fixed-length-tp5730980p5731093.html Sent from the Camel - Users mailing list archive at Nabble.com.

consumer.bridgeErrorHandler=true on netty uri

Hi, I tried to use consumer.bridgeErrorHandler=true on a netty endpoint but it had no effect. From what I see from Camel's source, it looks like this parameter is not used although NettyConsumer extends DefaultConsumer. Is there any way to bridge the exceptionHandler to the errorHandler in netty c

Re: Bindy fixed length

Sorry, after I wrote the post I felt it wasn't clear enough too... I wanted to ask if there was a feature to similar to Hibernate's components (or BeanIO segments) to break the bean into a root bean and smaller nested beans. For example, let's suppose I have this line: NAME--LAST_NAME-ADDRESS

Bindy fixed length

Hi, Is there anything similar to Hibernate's components in bindy? It would be nice if we can nest objects to model one line. Thanks. -- View this message in context: http://camel.465427.n5.nabble.com/Bindy-fixed-length-tp5730980.html Sent from the Camel - Users mailing list archive at Nabble.

How to know if a component is InOnly by default

In http://camel.apache.org/event-message.html it says that "The default behaviour of many Components is InOnly such as for JMS, File or SEDA". How can I know if a specific component is InOnly? For example, the "direct" component. Thanks. -- View this message in context: http://camel.465427.n5.