public void init ( ) { pipeline = pipeline ( ) ; pipeline . addLast ( "messageBufferEventDecoder" , messageBufferEventDecoder ) ; pipeline . addLast ( "upstream" , upstream ) ; // Downstream handlers - Filter for data which flows from server to // client. Note that the last handler added is actually the first // handler for outgoing data. pipeline . addLast ( "messageBufferEventEncoder" , messageBufferEventEncoder ) ; }
This method creates a single pipeline object that will be shared for all the channels .