You should use the options of decoders and encoders.
The netty endpoint doesn't support the option of encoder and decoder.
On Tue Feb 14 12:46:27 2012, xiangqiuzhao wrote:
I change the URI with
.to("netty:tcp://localhost:6789?encoder=#myEncoder&decoder=#myDecoder&sync=true").
but the same exception be throw.
the whole code like:
Object decoder = new LengthDecoder(); //appctx.getBean("mydecoder");
Object encoder = new MessageEncoder(10);
//appctx.getBean("myencoder");
SimpleRegistry registry = new SimpleRegistry();
List<ChannelDownstreamHandler> encoders = new
ArrayList<ChannelDownstreamHandler>();
List<ChannelUpstreamHandler> decoders = new
ArrayList<ChannelUpstreamHandler>();
encoders.add((ChannelDownstreamHandler)encoder);
decoders.add((ChannelUpstreamHandler)decoder);
registry.put("myDecoder", decoder);
registry.put("myEncoder", encoder);
registry.put("myEncoders", encoders);
registry.put("myDecoders", decoders);
CamelContext context = new DefaultCamelContext(registry);
context.addRoutes(new RouteBuilder() {
public void configure() throws Exception {
from("direct:cpsp")
.process(new MyToProcessor())
//.to("netty:tcp://localhost:6789?encoders=#myEncoders&decoders=myDecoders&sync=true")
.to("netty:tcp://localhost:6789?encoder=#myEncoder&decoder=#myDecoder&sync=true")
.process(new MyFromProcessor());
}
});
--
View this message in context:
http://camel.465427.n5.nabble.com/about-netty-encoder-and-encoders-tp5479417p5481472.html
Sent from the Camel - Users mailing list archive at Nabble.com.
--
Willem
----------------------------------
FuseSource
Web: http://www.fusesource.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.javaeye.com (Chinese)
Twitter: willemjiang
Weibo: willemjiang
