code: async def ack(self, msg):
          
          ack_proto = protocol.Ack()
          ack_proto.subject = msg.proto.subject
          ack_proto.sequence = msg.proto.sequence
          await self._nc.publish(msg.sub.ack_inbox, ack_proto.SerializeToString())
docs: Used to manually acks a message.
  
          :param msg: Message which is pending to be acked by client.