从 JMS 侦听器 onMessage() 提交时,批处理作业卡在 STARTING
Batch job is stuck at STARTING when submited from a JMS Listener onMessage()
我正在尝试根据 JSR 352 规范使用从 BatchRuntime 获得的 JobOperator
在 JMS MessageListener 的 onMessage(...)
方法中启动批处理作业。
JobOperator jobOperator = BatchRuntime.getJobOperator();
Properties props = new Properties();
props.setProperty("sourceFile", "data_file.csv");
jobOperator.start("batchTask", props);
结果是作业执行停滞在 STARTING。当我尝试从同一个线程停止任务时,它同样停留在 STOPPING。
从普通 HttpServlet
开始同一个作业,它会立即运行到完成。为什么会这样?
您应该使用 MDB 在 EE 应用程序服务器中使用 JMS 消息,而不是您自己的 MessageListener。 (参见 here。)
批处理需要在托管线程上 运行 以便 EE 上下文可用,以便 ManagedExecutorService 等 EE API 用作批处理 "thread pool"将正常运行。
在使用非托管线程时,除了批处理(以及潜在的其他应用程序服务器功能)之外,其他 EE API 也会存在潜在问题,这就是为什么 MDB 是此处的必要方法。
我正在尝试根据 JSR 352 规范使用从 BatchRuntime 获得的 JobOperator
在 JMS MessageListener 的 onMessage(...)
方法中启动批处理作业。
JobOperator jobOperator = BatchRuntime.getJobOperator();
Properties props = new Properties();
props.setProperty("sourceFile", "data_file.csv");
jobOperator.start("batchTask", props);
结果是作业执行停滞在 STARTING。当我尝试从同一个线程停止任务时,它同样停留在 STOPPING。
从普通 HttpServlet
开始同一个作业,它会立即运行到完成。为什么会这样?
您应该使用 MDB 在 EE 应用程序服务器中使用 JMS 消息,而不是您自己的 MessageListener。 (参见 here。)
批处理需要在托管线程上 运行 以便 EE 上下文可用,以便 ManagedExecutorService 等 EE API 用作批处理 "thread pool"将正常运行。
在使用非托管线程时,除了批处理(以及潜在的其他应用程序服务器功能)之外,其他 EE API 也会存在潜在问题,这就是为什么 MDB 是此处的必要方法。