code: @Override
    public void write(final T message) {
      LOG.log(Level.FINEST, "write {0} :: {1}", new Object[] {channel, message});
      final ChannelFuture future = channel.writeAndFlush(Unpooled.wrappedBuffer(encoder.encode(message)));
      if (listener !=  null) {
        future.addListener(new NettyChannelFutureListener<>(message, listener));
      }
    }
docs: Writes the message to this link.
  
  @param message the message