public ChannelHandler [ ] getServerChannelHandlers ( ) { PartitionRequestQueue queueOfPartitionQueues = new PartitionRequestQueue ( ) ; PartitionRequestServerHandler serverHandler = new PartitionRequestServerHandler ( partitionProvider , taskEventPublisher , queueOfPartitionQueues , creditBasedEnabled ) ; return new ChannelHandler [ ] { messageEncoder , new NettyMessage . NettyMessageDecoder ( ! creditBasedEnabled ) , serverHandler , queueOfPartitionQueues } ; }
Returns the server channel handlers .