### Question:
DelegatingInboundHandler extends ChannelInboundHandlerAdapter { @Override public void channelRead(final ChannelHandlerContext ctx, final Object msg) { consumer.consume((DataObject) msg); } DelegatingInboundHandler(final MessageConsumer connectionAdapter); @Override void channelRead(final ChannelHandlerContext ctx, final Object msg); @Override void channelInactive(final ChannelHandlerContext ctx); @Override void channelUnregistered(final ChannelHandlerContext ctx);  }### Answer:
@Test public void testChannelReadSuccess() { dih.channelRead(mockChHndlrCtx, mockDataObject) ; verify( mockMsgConsumer, times(1)).consume(mockDataObject); }