Проблема с очередью задач?

Я работаю с очередью задач Google App Engine. Это мой первый раз. Я нашел учебник, но возникли некоторые проблемы. Ниже приведены два сервлета, которые я использую для проверки очереди задач:

 public class GAEJSignupSubscriberServlet extends HttpServlet {

   private static final Logger _logger = Logger.getLogger(GAEJSignupSubscriberServlet.class.getName());


public void doGet(HttpServletRequest req, HttpServletResponse resp)
        throws ServletException, IOException {


    resp.setContentType("text/plain");
    resp.getWriter().println("Hello, world");

    String strCallResult = "";
    resp.setContentType("text/plain");
    try {
        String strEmailId = req.getParameter("emailid");
        _logger.info("Got a Signup Subscriber Request for Email ID : " + strEmailId);
        //
        // PUT YOUR TASK CODE HERE
        //
        if(strEmailId.equals("mh")){
        System.out.println("email-id" + strEmailId);
        }
        strCallResult = "SUCCESS: Subscriber Signup";
        _logger.info(strCallResult);
        resp.getWriter().println(strCallResult);
        }
        catch (Exception ex) {
        strCallResult = "FAIL: Subscriber Signup : " + ex.getMessage();
        _logger.info(strCallResult);
        resp.getWriter().println(strCallResult);
        }
}
@Override
    public void doPost(HttpServletRequest req, HttpServletResponse resp)
       throws ServletException, IOException {
          doGet(req, resp);
    }

 }

второй сервлет:

  public class GAEJCreateTaskServlet extends HttpServlet {

public void doGet(HttpServletRequest req, HttpServletResponse resp)
throws IOException {
    this.doPost(req, resp);
}

public void doGet(HttpServletRequest req, HttpServletResponse resp)
        throws IOException {
    resp.setContentType("text/plain");
    resp.getWriter().println("Hello, world");

    String strCallResult = "";
    resp.setContentType("text/plain");
    try {
        //Extract out the To, Subject and Body of the Email to be sent
        String strEmailId = req.getParameter("emailid");

        //Do validations here. Only basic ones i.e. cannot be null/empty

        if (strEmailId == null) throw new Exception("Email Id field cannot be empty.");

        //Trim the stuff
        strEmailId = strEmailId.trim();
        if (strEmailId.length() == 0) throw new Exception("Email Id field cannot be empty.");
        //Queue queue = QueueFactory.getDefaultQueue();
        Queue queue = QueueFactory.getQueue("subscription-queue");
        queue.add(TaskOptions.Builder.withUrl("/gaejsignupsubscriber").param("emailid",strEmailId));
        strCallResult = "Successfully created a Task in the Queue";
        resp.getWriter().println(strCallResult);
        }
        catch (Exception ex) {
        strCallResult = "Fail: " + ex.getMessage();
        resp.getWriter().println(strCallResult);
        }
}
    @Override
    public void doPost(HttpServletRequest req, HttpServletResponse resp)
       throws ServletException, IOException {
          doGet(req, resp);
    }

 }

Я вызываю GAEJCreateTaskServlet с этим URL:

 http://localhost:8080/[email protected]

теперь проблема в том, что когда я вызываю этот URL-адрес, я вижу вывод о том, что задача создана, но в консоли разработки я не вижу ни одной задачи в очереди. Если я удаляю функцию doPost из обоих сервлетов, я вижу задачу в очереди, но когда я ее запускаю, ничего не происходит, и задачи остаются там. Почему так происходит и как решить эту проблему. Заранее спасибо.


person Piscean    schedule 29.07.2011    source источник


Ответы (3)


Скорее всего, вы не видите задачу, потому что она уже выполнена. Проверьте свои журналы (консоль в разработке или страницу ведения журнала на рабочей консоли администратора), чтобы увидеть, какое исключение вызывает ваш обработчик задач (если есть), и исправьте его.

person Nick Johnson    schedule 01.08.2011

Не уверен, что у вас должен быть этот метод doGet. У вас есть 2 с одинаковой подписью, но это не должно решить вашу проблему, если вы говорите, что печатает сообщение об успешном завершении.

public void doGet(HttpServletRequest req, HttpServletResponse resp)
throws IOException {
    this.doPost(req, resp);
}
person Ismael    schedule 05.08.2011

GAEJSignupSubscriberServlet не нужно устанавливать тип содержимого ответа или записывать ответ. Поскольку сервлет вызывается из задачи, ответ никогда не виден, представьте, что он отправляется в /dev/null. Вы должны войти из сервлета.

GAEJSignupSubscriberServlet не нуждается ни в каких методах doGet, только в doPost, так как задачи создаются методом POST по умолчанию. Если вы предпочитаете использовать GET, настройте TaskOptions с помощью метода (TaskOptions.Method.GET)

person Eric Willigers    schedule 25.06.2012