Google App Engine：在 JUnit 测试用例中使用 TaskQueue 时出现异常

Question

我想从 Junit 测试用例中调用任务队列。我的代码是：

@Test
    public void monthlyCronTest1() throws Exception {
....
       Queue queue = QueueFactory.getQueue("updateVcoCron");
       TaskOptions options = TaskOptions.Builder.withUrl(String.format("/api/v1/users/update/validation/points")).method(TaskOptions.Method.GET);
                    options.param("pageNumber", String.valueOf(pageNumber));
                    options.param("validatableBrands", validatableBrands);
          queue.add(options); // this line throw exception
......
}

这里我收到错误：

 Exception:java.lang.IllegalStateException: The specified queue is unknown : updateVcoCron
    [junit] 1577867 INFO  org.quartz.impl.StdSchedulerFactory  - Quartz scheduler 'DefaultQuartzScheduler' initialized f
rom default resource file in Quartz package: 'quartz.properties'
    [junit] 1577867 INFO  org.quartz.impl.StdSchedulerFactory  - Quartz scheduler version: UNKNOWN.UNKNOWN.UNKNOWN
    [junit] 1577867 INFO  org.quartz.core.QuartzScheduler  - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED started.

2）如果我使用默认队列，例如：

   Queue queue = QueueFactory.getDefaultQueue();

我得到了不同的错误。

    [junit] com.google.apphosting.api.ApiProxy$ApplicationException: ApplicationError: 2: Received exception executing h
ttp method GET against URL http://localhost:8080/api/v1/users/update/validation/points?pageNumber=1&validatableBrands=Vi
rgin+Trains: Connection to http://localhost:8080 refused
    [junit]     at com.google.appengine.api.urlfetch.dev.LocalURLFetchService.fetch(LocalURLFetchService.java:412)
    [junit]     at com.google.appengine.api.taskqueue.dev.LocalTaskQueue$UrlFetchServiceLocalTaskQueueCallback.execute(L
ocalTaskQueue.java:701)
    [junit]     at com.google.appengine.api.taskqueue.dev.UrlFetchJob.execute(UrlFetchJob.java:90)
    [junit]     at org.quartz.core.JobRunShell.run(JobRunShell.java:203)
    [junit]     at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:520)
    [junit] 432275 ERROR org.quartz.core.ErrorLogger  - Job (default.task-1a8a7b8a-db49-432e-ac3d-cce784211b8a threw an
exception.

我的queue.xml位于以下路径中：

src/main/webapp/WEB-INF。

现在我的问题是：JUnit 环境还有配置吗？为什么它不选择queue.xml？请在这里帮忙。

Answer 1

我遇到了“指定的队列未知”错误。查看此解决方案后https://stackoverflow.com/a/11200214/2742117，我通过将其添加到我的基本测试类来修复它

private static String dir;
static {
  dir = System.getProperty("user.dir") + "/src/main/webapp/WEB-INF/queue.xml";
  System.out.println(dir);
}

protected final LocalServiceTestHelper helper =
  new LocalServiceTestHelper(
      //some other configurations removed for brevity...
      new LocalTaskQueueTestConfig().setQueueXmlPath(dir)
  );

此后，我的测试能够使用我的非默认队列。

Answer 2

我不是在单元测试中遇到这个问题，而是在现实中遇到这个问题。最后我必须在我的queue.xml中实际添加新队列

<queue>
    <name>myNewQueue</name>
    <rate>100/s</rate>
    <max-concurrent-requests>100</max-concurrent-requests>
    <retry-parameters>
        <task-age-limit>300h</task-age-limit>
        <min-backoff-seconds>10</min-backoff-seconds>
        <max-backoff-seconds>200</max-backoff-seconds>
        <max-doublings>0</max-doublings>
    </retry-parameters>
    <target>my-queue-service</target>
</queue>