Short update: implementing a custom JobExecutor turns out to be quite easy, and we can send JMS messages from it to a @MessageDriven bean. That bean has CDI services enabled and will execute the job via managementService.executeJob(). Some code:
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.inject.Inject;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import org.activiti.engine.ProcessEngine;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@MessageDriven(activationConfig = {
@ActivationConfigProperty(propertyName = "destination", propertyValue = "java:/jms/queue/activitiJobExecutor"),
@ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue") })
public class JobExecutorBean implements MessageListener {
protected static Logger log = LoggerFactory.getLogger(JobExecutorBean.class);
@Inject
protected ProcessEngine processEngine;
@Override
public void onMessage(Message message) {
String jobId = getJobIdFromMessage(message);
if (jobId != null) {
processEngine.getManagementService().executeJob(jobId);
}
}
protected String getJobIdFromMessage(Message message) {
if (message instanceof TextMessage) {
try {
TextMessage textMessage = (TextMessage) message;
log.debug("Recevied message over JMS: '{}'", textMessage.getText());
return textMessage.getText();
} catch (JMSException e) {
log.error("Error occured while reading JMS TextMessage", e);
return null;
}
}
return null;
}
}
The custom JobExecutor basically just connects to the JMS queue obtained via JNDI and posts the Job IDs to that queue in it's executeJobs() method. Basically the MDB replaces the class ExecutorJobsRunnable which DefaultJobExecutor uses to run jobs in it's thread pool. Both ExecutorJobsRunnable and the MDB rely on ExecuteJobsCmd() to do the rest 🙂 Of course this is totally untested, but in case anybody has the same requirement, it might be helpful…
Now let's take a serious look at fox platform ce where this is supposed to be all pretty 🙂
