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
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.
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
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
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.
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
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
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
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
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
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
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
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
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.
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.
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
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
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.
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
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
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
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
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")
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.
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 =
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
26 matches
Mail list logo