2525import io .netty .channel .ChannelInboundHandlerAdapter ;
2626
2727public abstract class VLBPipeline extends ChannelInboundHandlerAdapter {
28- public static final String HANDLER_DECODER_NAME = "via-decoder" ;
29- public static final String HANDLER_ENCODER_NAME = "via-encoder" ;
28+ public static final String VIA_DECODER_HANDLER_NAME = "via-decoder" ;
29+ public static final String VIA_ENCODER_HANDLER_NAME = "via-encoder" ;
3030
3131 private final UserConnection info ;
3232
@@ -38,8 +38,8 @@ public VLBPipeline(final UserConnection info) {
3838 public void handlerAdded (ChannelHandlerContext ctx ) throws Exception {
3939 super .handlerAdded (ctx );
4040
41- ctx .pipeline ().addBefore (getDecoderHandlerName (), HANDLER_DECODER_NAME , this .createVLBViaDecodeHandler ());
42- ctx .pipeline ().addBefore (getEncoderHandlerName (), HANDLER_ENCODER_NAME , this .createVLBViaEncodeHandler ());
41+ ctx .pipeline ().addBefore (getDecoderHandlerName (), VIA_DECODER_HANDLER_NAME , this .createVLBViaDecodeHandler ());
42+ ctx .pipeline ().addBefore (getEncoderHandlerName (), VIA_ENCODER_HANDLER_NAME , this .createVLBViaEncodeHandler ());
4343 }
4444
4545 @ Override
@@ -49,15 +49,15 @@ public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exc
4949 final int decoderIndex = ctx .pipeline ().names ().indexOf (getDecompressionHandlerName ());
5050 if (decoderIndex == -1 ) return ;
5151
52- if (decoderIndex > ctx .pipeline ().names ().indexOf (HANDLER_DECODER_NAME )) {
53- final ChannelHandler decoder = ctx .pipeline ().get (HANDLER_DECODER_NAME );
54- final ChannelHandler encoder = ctx .pipeline ().get (HANDLER_ENCODER_NAME );
52+ if (decoderIndex > ctx .pipeline ().names ().indexOf (VIA_DECODER_HANDLER_NAME )) {
53+ final ChannelHandler decoder = ctx .pipeline ().get (VIA_DECODER_HANDLER_NAME );
54+ final ChannelHandler encoder = ctx .pipeline ().get (VIA_ENCODER_HANDLER_NAME );
5555
56- ctx .pipeline ().remove (encoder );
5756 ctx .pipeline ().remove (decoder );
57+ ctx .pipeline ().remove (encoder );
5858
59- ctx .pipeline ().addAfter (getDecompressionHandlerName (), HANDLER_DECODER_NAME , decoder );
60- ctx .pipeline ().addAfter (getCompressionHandlerName (), HANDLER_ENCODER_NAME , encoder );
59+ ctx .pipeline ().addAfter (getDecompressionHandlerName (), VIA_DECODER_HANDLER_NAME , decoder );
60+ ctx .pipeline ().addAfter (getCompressionHandlerName (), VIA_ENCODER_HANDLER_NAME , encoder );
6161 }
6262 }
6363
0 commit comments