code: public ChannelFuture send(Message message) throws NotConnectedException {
          if (!connected) {
              throw new NotConnectedException();
          }
  
          if (log.isDebugEnabled()) {
              log.debug(">>> {}", message.toString().trim());
          }
  
          return channel.write(message);
      }
docs: Send a message through this connection