RE: about netty encoder and encoders...

[xiangqiuzhao]

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.