ejbworkflowstore.java

一个很好实用的工作流OSWORKFLOW开发例子.有着非常优秀的灵活性.

/*
 * Copyright (c) 2002-2003 by OpenSymphony
 * All rights reserved.
 */
package com.opensymphony.workflow.spi.ejb;

import com.opensymphony.module.propertyset.PropertySet;
import com.opensymphony.module.propertyset.PropertySetManager;

import com.opensymphony.workflow.StoreException;
import com.opensymphony.workflow.query.WorkflowExpressionQuery;
import com.opensymphony.workflow.query.WorkflowQuery;
import com.opensymphony.workflow.spi.*;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import java.rmi.RemoteException;

import java.util.*;

import javax.naming.InitialContext;

import javax.rmi.PortableRemoteObject;


/**
 * EJB entity bean workflow store implementation.
 * <p>
 *
 * The following property is optional:
 * <ul>
 *  <li><b>property.store</b> - JNDI location for the OSCore EJBPropertySet PropertyStore (defaults to "ejb/propertyStore")</li>
 *  <li><b>workflow.store</b> - JNDI location for the ejb workflow store session bean (defaults to @link{#WorkflowStoreHome.JNDI_NAME)</li>
 * </ul>
 *
 * @author <a href="mailto:[e-mail]">Pat Lightbody</a>
 */
public class EJBWorkflowStore implements WorkflowStore {
    //~ Static fields/initializers /////////////////////////////////////////////

    private static final Log log = LogFactory.getLog(EJBWorkflowStore.class);

    //~ Instance fields ////////////////////////////////////////////////////////

    private WorkflowStoreRemote session;

    //~ Methods ////////////////////////////////////////////////////////////////

    public void setEntryState(long entryId, int state) throws StoreException {
        try {
            session.setEntryState(entryId, state);
        } catch (RemoteException ex) {
            log.error("Error changing state of workflow instance #" + entryId + " to " + state, ex);
        }
    }

    public PropertySet getPropertySet(long entryId) throws StoreException {
        try {
            HashMap args = new HashMap(2);
            args.put("entityId", new Long(entryId));
            args.put("entityName", "WorkflowEntry");

            return PropertySetManager.getInstance("ejb", args);
        } catch (Exception e) {
            throw new StoreException("Could not retrieve PropertySet for workflow instance #" + entryId, e);
        }
    }

    public Step createCurrentStep(long entryId, int stepId, String owner, Date startDate, Date dueDate, String status, long[] previousIds) throws StoreException {
        try {
            return session.createCurrentStep(entryId, stepId, owner, startDate, dueDate, status, previousIds);
        } catch (RemoteException ex) {
            log.fatal("System error", ex);

            return null;
        }
    }

    public WorkflowEntry createEntry(String workflowName) throws StoreException {
        try {
            return session.createEntry(workflowName);
        } catch (RemoteException ex) {
            log.fatal("System error", ex);

            return null;
        }
    }

    public List findCurrentSteps(long entryId) throws StoreException {
        try {
            return session.findCurrentSteps(entryId);
        } catch (RemoteException ex) {
            log.fatal("System error", ex);

            return null;
        }
    }

    public WorkflowEntry findEntry(long entryId) throws StoreException {
        try {
            return session.findEntry(entryId);
        } catch (RemoteException ex) {
            log.fatal("System error", ex);

            return null;
        }
    }

    public List findHistorySteps(long entryId) throws StoreException {
        try {
            return session.findHistorySteps(entryId);
        } catch (RemoteException ex) {
            log.fatal("System error", ex);

            return null;
        }
    }

    public void init(Map props) {
        String workflowSessionLocation = (String) props.get("workflow.store");

        if (workflowSessionLocation == null) {
            workflowSessionLocation = WorkflowStoreHomeFactory.JNDI_NAME;
        }

        try {
            InitialContext context = new InitialContext();
            session = ((WorkflowStoreHome) PortableRemoteObject.narrow(context.lookup(workflowSessionLocation), WorkflowStoreHome.class)).create();
        } catch (Exception ex) {
            log.error("Error looking up homes", ex);
            throw new IllegalArgumentException(ex.toString());
        }
    }

    public Step markFinished(Step step, int actionId, Date finishDate, String status, String caller) throws StoreException {
        try {
            return session.markFinished(step, actionId, finishDate, status, caller);
        } catch (RemoteException ex) {
            log.fatal("System error", ex);

            return null;
        }
    }

    public void moveToHistory(Step step) throws StoreException {
        try {
            session.moveToHistory(step);
        } catch (RemoteException ex) {
            log.fatal("System error", ex);
        }
    }

    public List query(WorkflowQuery query) {
        // not implemented
        throw new UnsupportedOperationException("EJB store does not support queries");
    }

    public List query(WorkflowExpressionQuery query) throws StoreException {
        throw new UnsupportedOperationException("EJB store does not support queries");
    }
}