jobimpl.java

一个java工作流引擎

package org.jbpm.model.scheduler.impl;

import java.util.*;
import org.apache.commons.logging.*;
import org.jbpm.delegation.*;
import org.jbpm.model.definition.impl.*;
import org.jbpm.model.execution.impl.*;
import org.jbpm.persistence.*;
import org.jbpm.service.*;

public class JobImpl {

  private Long id = null;
  private DelegationImpl actionDelegation = null;
  private Date dueDate = null;
  private Long repeat = null;
  private String reference = null;
  private TokenImpl token = null;
  private ProcessInstanceImpl processInstance = null;
  
  public JobImpl () {}
  
  public JobImpl ( DelegationImpl actionDelegation, 
                   TokenImpl token, 
                   ProcessInstanceImpl processInstance,
                   Date dueDate,
                   String reference ) {
    this.actionDelegation = actionDelegation;
    this.token = token;
    this.processInstance = processInstance;
    this.dueDate = dueDate;
    this.reference = reference;
  }
  
  public Long getId() { return this.id; }
  public void setId(Long id) { this.id = id; }

  public DelegationImpl getActionDelegation() { return actionDelegation; }
  public void setActionDelegation(DelegationImpl actionDelegation) { this.actionDelegation = actionDelegation; }

  public Date getDueDate() { return dueDate; }
  public void setDueDate(Date dueDate) { this.dueDate = dueDate; }
  
  public Long getRepeat() { return repeat; }
  public void setRepeat(Long repeat) { this.repeat = repeat; }

  public ProcessInstanceImpl getProcessInstance() { return processInstance; }
  public void setProcessInstance(ProcessInstanceImpl processInstance) { this.processInstance = processInstance; }

  public TokenImpl getToken() { return token; }
  public void setToken(TokenImpl token) { this.token = token; }
  
  public String getReference() { return reference; }
  public void setReference(String reference) { this.reference = reference;}

  public void execute( ExecutionServiceImpl executionService, PersistenceSessionTx sessionTx ) {
    ActionHandler actionHandler = (ActionHandler) actionDelegation.instantiate();
    ExecutionContextImpl executionContext = new ExecutionContextImpl("scheduler", sessionTx, executionService );

    if ( token != null ) {
      executionContext.setToken( token );
    } else if ( processInstance != null ) {
      executionContext.setToken( (TokenImpl) processInstance.getRoot() );
    }
    
    try {
      actionHandler.execute( executionContext );
    } catch (RuntimeException e) {
      log.error( "runtime exception while executing job", e );
    }
  }

  private static Log log = LogFactory.getLog(JobImpl.class);
}