14:03:26.944 [main] DEBUG o.a.c.i.DefaultExecutorServiceStrategy -
ShutdownNow ExecutorService:
java.util.concurrent.Executors$FinalizableDelegatedExecutorService@140984b
14:03:26.944 [main] INFO o.a.c.impl.DefaultInflightRepository - Shutting
down with no inflight exchanges.
14:03:26.944 [main] DEBUG o.a.c.impl.SharedProducerServicePool - Stopping
service pool: org.apache.camel.impl.SharedProducerServicePool@15db314
14:03:26.944 [main] DEBUG o.a.c.component.netty.NettyProducer - Stopping
producer at address: localhost:6789
14:03:26.961 [main] INFO com.sunyard.camel.LengthDecoder - in Length
decoder:0
readable not enough
CamelContext context = new DefaultCamelContext(registry);
from("direct://local").to("netty:tcp://localhost:6789?encoders=#myEncoders&decoders=myDecoders&sync=true")
//...
context.stop();
MyDecoder's decode method:
LOG.info("in Length decoder:" + buffer.readableBytes());
when the context stop, the log output "LengthDecoder - in Length decoder:0"
.why the decoder be called?
--
View this message in context:
http://camel.465427.n5.nabble.com/why-decoder-called-when-netty-component-stopping-tp5643027p5643027.html
Sent from the Camel - Users mailing list archive at Nabble.com.
