Extend ChannelCircuitBreakerHandler with ChannelOutboundHandlerAdapter

instead of ChannelDuplexHandler

Author: ameya-signal

service/src/main/java/org/whispersystems/textsecuregcm/redis/LettuceShardCircuitBreaker.java

@@ -19,8 +19,8 @@
 import io.lettuce.core.resource.NettyCustomizer;
 import io.micrometer.core.instrument.Tags;
 import io.netty.channel.Channel;
-import io.netty.channel.ChannelDuplexHandler;
 import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelOutboundHandlerAdapter;
 import io.netty.channel.ChannelPromise;
 import java.net.SocketAddress;
 import java.util.Collection;
@@ -120,7 +120,7 @@ public void afterChannelInitialized(final Channel channel) {
     channel.pipeline().addBefore(commandHandlerName, null, channelCircuitBreakerHandler);
   }
 
-  static final class ChannelCircuitBreakerHandler extends ChannelDuplexHandler {
+  static final class ChannelCircuitBreakerHandler extends ChannelOutboundHandlerAdapter {
 
     private static final Logger logger = LoggerFactory.getLogger(ChannelCircuitBreakerHandler.class);