[jbpm-commits] JBoss JBPM SVN: r6264 - in projects/exception_framework/trunk: src and 16 other directories.

Author: eschabell Date: 2010-04-20 14:27:47 -0400 (Tue, 20 Apr 2010) New Revision: 6264 Added: projects/exception_framework/trunk/pom.xml projects/exception_framework/trunk/src/ projects/exception_framework/trunk/src/main/ projects/exception_framework/trunk/src/main/config/ projects/exception_framework/trunk/src/main/config/hibernate.cfg.hsqldb.xml projects/exception_framework/trunk/src/main/config/hibernate.cfg.xml projects/exception_framework/trunk/src/main/config/jbpm-hsqldb-ds.xml projects/exception_framework/trunk/src/main/config/jbpm.cfg.xml projects/exception_framework/trunk/src/main/config/jbpm.mail.templates.xml projects/exception_framework/trunk/src/main/config/log4j.properties projects/exception_framework/trunk/src/main/config/version.info.xml projects/exception_framework/trunk/src/main/java/ projects/exception_framework/trunk/src/main/java/org/ projects/exception_framework/trunk/src/main/java/org/jboss/ projects/exception_framework/trunk/src/main/java/org/jboss/handler/ projects/exception_framework/trunk/src/main/java/org/jboss/handler/AbstractExceptionActionHandler.java projects/exception_framework/trunk/src/main/java/org/jboss/handler/DetermineExceptionHandlingHandler.java projects/exception_framework/trunk/src/main/java/org/jboss/handler/HumanTaskHandler.java projects/exception_framework/trunk/src/main/java/org/jboss/handler/RetryHandler.java projects/exception_framework/trunk/src/main/java/org/jboss/handler/StartExceptionFrameworkHandler.java projects/exception_framework/trunk/src/main/java/org/jboss/handler/TriggerOriginatingProcessHandler.java projects/exception_framework/trunk/src/main/java/org/jboss/util/ projects/exception_framework/trunk/src/main/java/org/jboss/util/ThreadPoolSingleton.java projects/exception_framework/trunk/src/main/jpdl/ projects/exception_framework/trunk/src/main/jpdl/process/ projects/exception_framework/trunk/src/main/jpdl/process/gpd.xml projects/exception_framework/trunk/src/main/jpdl/process/processdefinition.xml projects/exception_framework/trunk/src/main/jpdl/process/processimage.jpg projects/exception_framework/trunk/src/test/ projects/exception_framework/trunk/src/test/java/ projects/exception_framework/trunk/src/test/java/org/ projects/exception_framework/trunk/src/test/java/org/jboss/ projects/exception_framework/trunk/src/test/java/org/jboss/handler/ projects/exception_framework/trunk/src/test/java/org/jboss/handler/ExceptionThrowingHandler.java projects/exception_framework/trunk/src/test/java/org/jboss/test/ projects/exception_framework/trunk/src/test/java/org/jboss/test/TestForNodeExceptionHandling.java projects/exception_framework/trunk/src/test/java/org/jboss/util/ projects/exception_framework/trunk/src/test/java/org/jboss/util/ProcessDefinitionReference.java projects/exception_framework/trunk/src/test/java/org/jboss/util/TaskCallback.java Modified: projects/exception_framework/trunk/ projects/exception_framework/trunk/readme.txt Log: Initial project code commit, working node unit test that makes use of an exception framework, see readme for details. Property changes on: projects/exception_framework/trunk ___________________________________________________________________ Name: svn:ignore + .settings bin target .classpath .project Added: projects/exception_framework/trunk/pom.xml =================================================================== --- projects/exception_framework/trunk/pom.xml (rev 0) +++ projects/exception_framework/trunk/pom.xml 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,70 @@ +<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> + <modelVersion>4.0.0</modelVersion> + <groupId>exception_framework</groupId> + <artifactId>exception_framework</artifactId> + <name>Exception Framework</name> + <version>0.0.1-SNAPSHOT</version> + <description>A generic jBPM exception framework.</description> + <build> + <plugins> + <plugin> + <groupId>org.codehaus.mojo</groupId> + <artifactId>surefire-report-maven-plugin</artifactId> + <version>2.0-beta-1</version> + </plugin> + </plugins> + </build> + <repositories> + <repository> + <id>jboss</id> + <name>Maven Repository jboss</name> + <layout>default</layout> + <url>http://repository.jboss.com/maven2/</url> + <snapshots> + <enabled>false</enabled> + </snapshots> + </repository> + </repositories> + <dependencies> + <dependency> + <groupId>junit</groupId> + <artifactId>junit</artifactId> + <version>4.8.1</version> + <scope>provided</scope> + </dependency> + <dependency> + <groupId>org.jbpm.jbpm3</groupId> + <artifactId>jbpm-jpdl</artifactId> + <version>3.2.8</version> + <scope>provided</scope> + </dependency> + <dependency> + <groupId>apache-log4j</groupId> + <artifactId>log4j</artifactId> + <version>1.2.15</version> + <type>jar</type> + <scope>provided</scope> + </dependency> + <dependency> + <groupId>org.hamcrest</groupId> + <artifactId>hamcrest-all</artifactId> + <version>1.1</version> + <type>jar</type> + <scope>provided</scope> + </dependency> + <dependency> + <groupId>org.mod4j.org.apache.commons</groupId> + <artifactId>lang</artifactId> + <version>2.1.0</version> + <type>jar</type> + <scope>provided</scope> + </dependency> + <dependency> + <groupId>org.hsqldb</groupId> + <artifactId>hsqldb</artifactId> + <version>1.8.0.10</version> + <type>jar</type> + <scope>provided</scope> + </dependency> + </dependencies> +</project> \ No newline at end of file Modified: projects/exception_framework/trunk/readme.txt =================================================================== --- projects/exception_framework/trunk/readme.txt 2010-04-20 17:54:48 UTC (rev 6263) +++ projects/exception_framework/trunk/readme.txt 2010-04-20 18:27:47 UTC (rev 6264) @@ -1,5 +1,16 @@ Project space to put together the results of a generic exception framework -example for jBPM v3.2.x. Coming soon... +example based on jBPM version 3.2.5.SP5. +Currently only running a test to show simple node failing, then passing exception and +all process context over to the Exception Framework. This framework defaults currently +to a Human Task for processing the error. In our test we end this task to continue +processing and go back to the originating process. + +TODO: State node failure example via unit test class. + +With my thanks to Maurice de Chateau for his contributions. + +Regards, Eric D. Schabell - +eric(a)schabell.org +erics(a)redhat.com \ No newline at end of file Added: projects/exception_framework/trunk/src/main/config/hibernate.cfg.hsqldb.xml =================================================================== --- projects/exception_framework/trunk/src/main/config/hibernate.cfg.hsqldb.xml (rev 0) +++ projects/exception_framework/trunk/src/main/config/hibernate.cfg.hsqldb.xml 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,263 @@ +<?xml version='1.0' encoding='utf-8'?> +<!DOCTYPE hibernate-configuration PUBLIC + "-//Hibernate/Hibernate Configuration DTD 3.0//EN" + "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"> + +<hibernate-configuration> + <session-factory> + + <!-- hibernate dialect --> + <property name="hibernate.dialect">org.hibernate.dialect.HSQLDialect</property> + + <!-- JDBC connection properties (begin) --> + <property name="hibernate.connection.driver_class">org.hsqldb.jdbcDriver</property> + <property name="hibernate.connection.url">jdbc:hsqldb:mem:jbpm</property> + <property name="hibernate.connection.username">sa</property> + <property name="hibernate.connection.password"></property> + <!-- JDBC connection properties (end) --> + + <!-- DataSource properties (begin) === + <property name="hibernate.connection.datasource">java:comp/env/jdbc/JbpmDataSource</property> + ==== DataSource properties (end) --> + + <!-- JTA transaction properties (begin) === + <property name="hibernate.transaction.factory_class">org.hibernate.transaction.JTATransactionFactory</property> + <property name="hibernate.transaction.manager_lookup_class">org.hibernate.transaction.JBossTransactionManagerLookup</property> + ==== JTA transaction properties (end) --> + + <!-- CMT transaction properties (begin) === + <property name="hibernate.transaction.factory_class">org.hibernate.transaction.CMTTransactionFactory</property> + <property name="hibernate.transaction.manager_lookup_class">org.hibernate.transaction.JBossTransactionManagerLookup</property> + ==== CMT transaction properties (end) --> + + <!-- ################################### --> + <!-- # common settings # --> + <!-- ################################### --> + + <!-- Automatic schema creation (begin) --> + <property name="hibernate.hbm2ddl.auto">create</property> + <!-- Automatic schema creation (end) --> + + <!-- Simple memory-only cache --> + <property name="hibernate.cache.provider_class">org.hibernate.cache.HashtableCacheProvider</property> + + <!-- SQL rendering properties --> + <property name="hibernate.format_sql">true</property> + <property name="hibernate.use_sql_comments">true</property> + + <!-- ############################################ --> + <!-- # mapping files with external dependencies # --> + <!-- ############################################ --> + + <!-- Additional mappings defined per module go here --> + <!--mapping resource="hibernate.extra.hbm.xml" /--> + <!--mapping resource="hibernate.identity.hbm.xml" /--> + + <!-- ###################### --> + <!-- # jbpm mapping files # --> + <!-- ###################### --> + + <!-- hql queries --> + <mapping resource="org/jbpm/db/hibernate.queries.hbm.xml" /> + + <!-- type mappings --> + <mapping resource="org/jbpm/db/hibernate.types.hbm.xml" /> + + <!-- hql queries used in simulation for querying historical data. + uncomment if you want to use the GetSimulationInputCommand + or you want to use the queries directly. + beware: the queries need the stddev function to be enabled in your dialect. + for more information, visit: + http://www.camunda.com/business_process_simulation_news/mysql_and_stddev.... --> + <!-- + <mapping resource="org/jbpm/sim/bam/hibernate.queries.hbm.xml" /> + --> + + <!-- graph.action mapping files --> + <mapping resource="org/jbpm/graph/action/MailAction.hbm.xml"/> + + <!-- graph.def mapping files --> + <mapping resource="org/jbpm/graph/def/ProcessDefinition.hbm.xml"/> + <mapping resource="org/jbpm/graph/def/Node.hbm.xml"/> + <mapping resource="org/jbpm/graph/def/Transition.hbm.xml"/> + <mapping resource="org/jbpm/graph/def/Event.hbm.xml"/> + <mapping resource="org/jbpm/graph/def/Action.hbm.xml"/> + <mapping resource="org/jbpm/graph/def/SuperState.hbm.xml"/> + <mapping resource="org/jbpm/graph/def/ExceptionHandler.hbm.xml"/> + <mapping resource="org/jbpm/instantiation/Delegation.hbm.xml"/> + + <!-- ########################################### --> + <!-- # mapping file with external dependencies # --> + <!-- ########################################### --> + <!-- the following mapping file has a dependency on 'bsh-{version}.jar'. + uncomment this if bsh is not in your classpath. + the script element will not be available in process definition files. + note: this mapping must appear below org/jbpm/graph/def/Action.hbm.xml --> + <mapping resource="org/jbpm/graph/action/Script.hbm.xml"/> + + <!-- graph.node mapping files --> + <mapping resource="org/jbpm/graph/node/StartState.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/EndState.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/ProcessState.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/Decision.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/Fork.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/Join.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/MailNode.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/State.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/TaskNode.hbm.xml"/> + + <!-- context.def mapping files --> + <mapping resource="org/jbpm/context/def/ContextDefinition.hbm.xml"/> + <mapping resource="org/jbpm/context/def/VariableAccess.hbm.xml"/> + + <!-- bytes mapping files --> + <mapping resource="org/jbpm/bytes/ByteArray.hbm.xml"/> + + <!-- module.def mapping files --> + <mapping resource="org/jbpm/module/def/ModuleDefinition.hbm.xml"/> + + <!-- file.def mapping files --> + <mapping resource="org/jbpm/file/def/FileDefinition.hbm.xml"/> + + <!-- taskmgmt.def mapping files --> + <mapping resource="org/jbpm/taskmgmt/def/TaskMgmtDefinition.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/def/Swimlane.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/def/Task.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/def/TaskController.hbm.xml"/> + + <!-- scheduler.def mapping files --> + <mapping resource="org/jbpm/scheduler/def/CreateTimerAction.hbm.xml"/> + <mapping resource="org/jbpm/scheduler/def/CancelTimerAction.hbm.xml"/> + + <!-- graph.exe mapping files --> + <mapping resource="org/jbpm/graph/exe/Comment.hbm.xml"/> + <mapping resource="org/jbpm/graph/exe/ProcessInstance.hbm.xml"/> + <mapping resource="org/jbpm/graph/exe/Token.hbm.xml"/> + <mapping resource="org/jbpm/graph/exe/RuntimeAction.hbm.xml"/> + + <!-- module.exe mapping files --> + <mapping resource="org/jbpm/module/exe/ModuleInstance.hbm.xml"/> + + <!-- context.exe mapping files --> + <mapping resource="org/jbpm/context/exe/ContextInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/TokenVariableMap.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/VariableInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/ByteArrayInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/DateInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/DoubleInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/HibernateLongInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/HibernateStringInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/LongInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/NullInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/StringInstance.hbm.xml"/> + + <!-- job mapping files --> + <mapping resource="org/jbpm/job/Job.hbm.xml"/> + <mapping resource="org/jbpm/job/Timer.hbm.xml"/> + <mapping resource="org/jbpm/job/ExecuteNodeJob.hbm.xml"/> + <mapping resource="org/jbpm/job/ExecuteActionJob.hbm.xml"/> + <mapping resource="org/jbpm/job/CleanUpProcessJob.hbm.xml"/> + + <!-- taskmgmt.exe mapping files --> + <mapping resource="org/jbpm/taskmgmt/exe/TaskMgmtInstance.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/exe/TaskInstance.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/exe/PooledActor.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/exe/SwimlaneInstance.hbm.xml"/> + + <!-- logging mapping files --> + <mapping resource="org/jbpm/logging/log/ProcessLog.hbm.xml"/> + <mapping resource="org/jbpm/logging/log/MessageLog.hbm.xml"/> + <mapping resource="org/jbpm/logging/log/CompositeLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/ActionLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/NodeLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/ProcessInstanceCreateLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/ProcessInstanceEndLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/ProcessStateLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/SignalLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/TokenCreateLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/TokenEndLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/TransitionLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/VariableLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/VariableCreateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/VariableDeleteLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/VariableUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/ByteArrayUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/DateUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/DoubleUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/HibernateLongUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/HibernateStringUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/LongUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/StringUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/TaskLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/TaskCreateLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/TaskAssignLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/TaskEndLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/SwimlaneLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/SwimlaneCreateLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/SwimlaneAssignLog.hbm.xml"/> + + <!-- ################## --> + <!-- # cache settings # --> + <!-- ##################--> + + <!-- strategy="nonstrict-read-write" can be used with HashtableCacheProvider --> + + <class-cache class="org.jbpm.bytes.ByteArray" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.bytes.ByteArray.byteBlocks" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.context.def.VariableAccess" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.file.def.FileDefinition.processFiles" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.graph.action.Script.variableAccesses" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.graph.def.Action" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.graph.def.Event" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Event.actions" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.graph.def.ExceptionHandler" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.ExceptionHandler.actions" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.graph.def.Node" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Node.events" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Node.exceptionHandlers" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Node.leavingTransitions" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Node.arrivingTransitions" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.graph.def.ProcessDefinition" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.ProcessDefinition.events" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.ProcessDefinition.exceptionHandlers" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.ProcessDefinition.nodes" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.ProcessDefinition.actions" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.ProcessDefinition.definitions" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.graph.def.SuperState.nodes" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.graph.def.Transition" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Transition.events" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Transition.exceptionHandlers" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.graph.node.Decision.decisionConditions" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.graph.node.ProcessState.variableAccesses" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.graph.node.TaskNode.tasks" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.instantiation.Delegation" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.module.def.ModuleDefinition" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.taskmgmt.def.Swimlane.tasks" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.taskmgmt.def.TaskController" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.taskmgmt.def.TaskController.variableAccesses" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.taskmgmt.def.Task" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.taskmgmt.def.Task.events" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.taskmgmt.def.Task.exceptionHandlers" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.taskmgmt.def.TaskMgmtDefinition.swimlanes" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.taskmgmt.def.TaskMgmtDefinition.tasks" usage="nonstrict-read-write" /> + </session-factory> +</hibernate-configuration> Property changes on: projects/exception_framework/trunk/src/main/config/hibernate.cfg.hsqldb.xml ___________________________________________________________________ Name: svn:executable + * Added: projects/exception_framework/trunk/src/main/config/hibernate.cfg.xml =================================================================== --- projects/exception_framework/trunk/src/main/config/hibernate.cfg.xml (rev 0) +++ projects/exception_framework/trunk/src/main/config/hibernate.cfg.xml 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,265 @@ +<?xml version='1.0' encoding='utf-8'?> +<!DOCTYPE hibernate-configuration PUBLIC + "-//Hibernate/Hibernate Configuration DTD 3.0//EN" + "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"> + +<hibernate-configuration> + <session-factory> + + <!-- hibernate dialect --> + <property name="hibernate.dialect">org.hibernate.dialect.HSQLDialect</property> + + <!-- JDBC connection properties (begin) --> + <property name="hibernate.connection.driver_class">org.hsqldb.jdbcDriver</property> + <property name="hibernate.connection.url">jdbc:hsqldb:mem:jbpm</property> + <property name="hibernate.connection.username">sa</property> + <property name="hibernate.connection.password"></property> + <!-- JDBC connection properties (end) --> + + <!-- DataSource properties (begin) === + <property name="hibernate.connection.datasource">java:comp/env/jdbc/JbpmDataSource</property> + ==== DataSource properties (end) --> + + <!-- JTA transaction properties (begin) === + <property name="jta.UserTransaction">UserTransaction</property> + <property name="hibernate.current_session_context_class">jta</property> + <property name="hibernate.transaction.factory_class">org.hibernate.transaction.JTATransactionFactory</property> + <property name="hibernate.transaction.manager_lookup_class">org.hibernate.transaction.JBossTransactionManagerLookup</property> + ==== JTA transaction properties (end) --> + + <!-- CMT transaction properties (begin) === + <property name="hibernate.transaction.factory_class">org.hibernate.transaction.CMTTransactionFactory</property> + <property name="hibernate.transaction.manager_lookup_class">org.hibernate.transaction.JBossTransactionManagerLookup</property> + ==== CMT transaction properties (end) --> + + <!-- ################################### --> + <!-- # common settings # --> + <!-- ################################### --> + + <!-- Automatic schema creation (begin) --> + <property name="hibernate.hbm2ddl.auto">create</property> + <!-- Automatic schema creation (end) --> + + <!-- Simple memory-only cache --> + <property name="hibernate.cache.provider_class">org.hibernate.cache.HashtableCacheProvider</property> + + <!-- SQL rendering properties --> + <property name="hibernate.format_sql">true</property> + <property name="hibernate.use_sql_comments">true</property> + + <!-- ############################################ --> + <!-- # mapping files with external dependencies # --> + <!-- ############################################ --> + + <!-- Additional mappings defined per module go here --> + <!-- mapping resource="hibernate.extra.hbm.xml" /--> + <!--mapping resource="hibernate.identity.hbm.xml" /--> + + <!-- ###################### --> + <!-- # jbpm mapping files # --> + <!-- ###################### --> + + <!-- hql queries --> + <mapping resource="org/jbpm/db/hibernate.queries.hbm.xml" /> + + <!-- type mappings --> + <mapping resource="org/jbpm/db/hibernate.types.hbm.xml" /> + + <!-- hql queries used in simulation for querying historical data. + uncomment if you want to use the GetSimulationInputCommand + or you want to use the queries directly. + beware: the queries need the stddev function to be enabled in your dialect. + for more information, visit: + http://www.camunda.com/business_process_simulation_news/mysql_and_stddev.... --> + <!-- + <mapping resource="org/jbpm/sim/bam/hibernate.queries.hbm.xml" /> + --> + + <!-- graph.action mapping files --> + <mapping resource="org/jbpm/graph/action/MailAction.hbm.xml"/> + + <!-- graph.def mapping files --> + <mapping resource="org/jbpm/graph/def/ProcessDefinition.hbm.xml"/> + <mapping resource="org/jbpm/graph/def/Node.hbm.xml"/> + <mapping resource="org/jbpm/graph/def/Transition.hbm.xml"/> + <mapping resource="org/jbpm/graph/def/Event.hbm.xml"/> + <mapping resource="org/jbpm/graph/def/Action.hbm.xml"/> + <mapping resource="org/jbpm/graph/def/SuperState.hbm.xml"/> + <mapping resource="org/jbpm/graph/def/ExceptionHandler.hbm.xml"/> + <mapping resource="org/jbpm/instantiation/Delegation.hbm.xml"/> + + <!-- ########################################### --> + <!-- # mapping file with external dependencies # --> + <!-- ########################################### --> + <!-- the following mapping file has a dependency on 'bsh-{version}.jar'. + uncomment this if bsh is not in your classpath. + the script element will not be available in process definition files. + note: this mapping must appear below org/jbpm/graph/def/Action.hbm.xml --> + <mapping resource="org/jbpm/graph/action/Script.hbm.xml"/> + + <!-- graph.node mapping files --> + <mapping resource="org/jbpm/graph/node/StartState.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/EndState.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/ProcessState.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/Decision.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/Fork.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/Join.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/MailNode.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/State.hbm.xml"/> + <mapping resource="org/jbpm/graph/node/TaskNode.hbm.xml"/> + + <!-- context.def mapping files --> + <mapping resource="org/jbpm/context/def/ContextDefinition.hbm.xml"/> + <mapping resource="org/jbpm/context/def/VariableAccess.hbm.xml"/> + + <!-- bytes mapping files --> + <mapping resource="org/jbpm/bytes/ByteArray.hbm.xml"/> + + <!-- module.def mapping files --> + <mapping resource="org/jbpm/module/def/ModuleDefinition.hbm.xml"/> + + <!-- file.def mapping files --> + <mapping resource="org/jbpm/file/def/FileDefinition.hbm.xml"/> + + <!-- taskmgmt.def mapping files --> + <mapping resource="org/jbpm/taskmgmt/def/TaskMgmtDefinition.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/def/Swimlane.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/def/Task.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/def/TaskController.hbm.xml"/> + + <!-- scheduler.def mapping files --> + <mapping resource="org/jbpm/scheduler/def/CreateTimerAction.hbm.xml"/> + <mapping resource="org/jbpm/scheduler/def/CancelTimerAction.hbm.xml"/> + + <!-- graph.exe mapping files --> + <mapping resource="org/jbpm/graph/exe/Comment.hbm.xml"/> + <mapping resource="org/jbpm/graph/exe/ProcessInstance.hbm.xml"/> + <mapping resource="org/jbpm/graph/exe/Token.hbm.xml"/> + <mapping resource="org/jbpm/graph/exe/RuntimeAction.hbm.xml"/> + + <!-- module.exe mapping files --> + <mapping resource="org/jbpm/module/exe/ModuleInstance.hbm.xml"/> + + <!-- context.exe mapping files --> + <mapping resource="org/jbpm/context/exe/ContextInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/TokenVariableMap.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/VariableInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/ByteArrayInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/DateInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/DoubleInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/HibernateLongInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/HibernateStringInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/LongInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/NullInstance.hbm.xml"/> + <mapping resource="org/jbpm/context/exe/variableinstance/StringInstance.hbm.xml"/> + + <!-- job mapping files --> + <mapping resource="org/jbpm/job/Job.hbm.xml"/> + <mapping resource="org/jbpm/job/Timer.hbm.xml"/> + <mapping resource="org/jbpm/job/ExecuteNodeJob.hbm.xml"/> + <mapping resource="org/jbpm/job/ExecuteActionJob.hbm.xml"/> + <mapping resource="org/jbpm/job/CleanUpProcessJob.hbm.xml"/> + + <!-- taskmgmt.exe mapping files --> + <mapping resource="org/jbpm/taskmgmt/exe/TaskMgmtInstance.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/exe/TaskInstance.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/exe/PooledActor.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/exe/SwimlaneInstance.hbm.xml"/> + + <!-- logging mapping files --> + <mapping resource="org/jbpm/logging/log/ProcessLog.hbm.xml"/> + <mapping resource="org/jbpm/logging/log/MessageLog.hbm.xml"/> + <mapping resource="org/jbpm/logging/log/CompositeLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/ActionLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/NodeLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/ProcessInstanceCreateLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/ProcessInstanceEndLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/ProcessStateLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/SignalLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/TokenCreateLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/TokenEndLog.hbm.xml"/> + <mapping resource="org/jbpm/graph/log/TransitionLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/VariableLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/VariableCreateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/VariableDeleteLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/VariableUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/ByteArrayUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/DateUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/DoubleUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/HibernateLongUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/HibernateStringUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/LongUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/context/log/variableinstance/StringUpdateLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/TaskLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/TaskCreateLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/TaskAssignLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/TaskEndLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/SwimlaneLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/SwimlaneCreateLog.hbm.xml"/> + <mapping resource="org/jbpm/taskmgmt/log/SwimlaneAssignLog.hbm.xml"/> + + <!-- ################## --> + <!-- # cache settings # --> + <!-- ##################--> + + <!-- strategy="nonstrict-read-write" can be used with HashtableCacheProvider --> + + <class-cache class="org.jbpm.bytes.ByteArray" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.bytes.ByteArray.byteBlocks" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.context.def.VariableAccess" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.file.def.FileDefinition.processFiles" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.graph.action.Script.variableAccesses" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.graph.def.Action" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.graph.def.Event" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Event.actions" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.graph.def.ExceptionHandler" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.ExceptionHandler.actions" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.graph.def.Node" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Node.events" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Node.exceptionHandlers" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Node.leavingTransitions" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Node.arrivingTransitions" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.graph.def.ProcessDefinition" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.ProcessDefinition.events" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.ProcessDefinition.exceptionHandlers" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.ProcessDefinition.nodes" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.ProcessDefinition.actions" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.ProcessDefinition.definitions" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.graph.def.SuperState.nodes" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.graph.def.Transition" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Transition.events" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.graph.def.Transition.exceptionHandlers" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.graph.node.Decision.decisionConditions" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.graph.node.ProcessState.variableAccesses" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.graph.node.TaskNode.tasks" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.instantiation.Delegation" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.module.def.ModuleDefinition" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.taskmgmt.def.Swimlane.tasks" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.taskmgmt.def.TaskController" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.taskmgmt.def.TaskController.variableAccesses" usage="nonstrict-read-write" /> + + <class-cache class="org.jbpm.taskmgmt.def.Task" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.taskmgmt.def.Task.events" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.taskmgmt.def.Task.exceptionHandlers" usage="nonstrict-read-write" /> + + <collection-cache collection="org.jbpm.taskmgmt.def.TaskMgmtDefinition.swimlanes" usage="nonstrict-read-write" /> + <collection-cache collection="org.jbpm.taskmgmt.def.TaskMgmtDefinition.tasks" usage="nonstrict-read-write" /> + </session-factory> +</hibernate-configuration> Property changes on: projects/exception_framework/trunk/src/main/config/hibernate.cfg.xml ___________________________________________________________________ Name: svn:executable + * Added: projects/exception_framework/trunk/src/main/config/jbpm-hsqldb-ds.xml =================================================================== --- projects/exception_framework/trunk/src/main/config/jbpm-hsqldb-ds.xml (rev 0) +++ projects/exception_framework/trunk/src/main/config/jbpm-hsqldb-ds.xml 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,32 @@ +<?xml version="1.0" encoding="UTF-8"?> +<datasources> + + <local-tx-datasource> + <jndi-name>JbpmDS</jndi-name> + + <connection-url>jdbc:hsqldb:${jboss.server.data.dir}${/}hypersonic${/}jbpmDB</connection-url> + <driver-class>org.hsqldb.jdbcDriver</driver-class> + <user-name>sa</user-name> + <password></password> + + <!-- disable idle connection removal, hsqldb does not reap threads on closed connections --> + <idle-timeout-minutes>0</idle-timeout-minutes> + <!-- check all statements are closed when the connection is returned to the pool --> + <track-statements /> + <!-- hsqldb benefits from prepared statement caching --> + <prepared-statement-cache-size>32</prepared-statement-cache-size> + + <!-- corresponding type-mapping in conf/standardjbosscmp-jdbc.xml --> + <type-mapping>Hypersonic SQL</type-mapping> + + <!-- ensure the datasource is not initialized before the database itself --> + <depends>jboss:service=Hypersonic,database=jbpmDB</depends> + </local-tx-datasource> + + <!-- for hsqldb accessed from jboss only, in-process (standalone) mode --> + <mbean code="org.jboss.jdbc.HypersonicDatabase" name="jboss:service=Hypersonic,database=jbpmDB"> + <attribute name="Database">jbpmDB</attribute> + <attribute name="InProcessMode">true</attribute> + </mbean> + +</datasources> Property changes on: projects/exception_framework/trunk/src/main/config/jbpm-hsqldb-ds.xml ___________________________________________________________________ Name: svn:executable + * Added: projects/exception_framework/trunk/src/main/config/jbpm.cfg.xml =================================================================== --- projects/exception_framework/trunk/src/main/config/jbpm.cfg.xml (rev 0) +++ projects/exception_framework/trunk/src/main/config/jbpm.cfg.xml 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,9 @@ +<jbpm-configuration> + + <!-- + The default configurations can be found in org/jbpm/default.jbpm.cfg.xml + Those configurations can be overwritten by putting this file called + jbpm.cfg.xml on the root of the classpath and put in the customized values. + --> + +</jbpm-configuration> Property changes on: projects/exception_framework/trunk/src/main/config/jbpm.cfg.xml ___________________________________________________________________ Name: svn:executable + * Added: projects/exception_framework/trunk/src/main/config/jbpm.mail.templates.xml =================================================================== --- projects/exception_framework/trunk/src/main/config/jbpm.mail.templates.xml (rev 0) +++ projects/exception_framework/trunk/src/main/config/jbpm.mail.templates.xml 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,24 @@ +<mail-templates> + + <variable name="BaseTaskListURL" value="http://localhost:8080/jbpm/home?taskId=" /> + + <mail-template name='task-assign'> + <actors>#{taskInstance.actorId}</actors> + <subject>Task '#{taskInstance.name}'</subject> + <text><![CDATA[Hi, +Task '#{taskInstance.name}' has been assigned to you. +Go for it: #{BaseTaskListURL}#{taskInstance.id} +Thanks. +---powered by JBoss jBPM---]]></text> + </mail-template> + + <mail-template name='task-reminder'> + <actors>#{taskInstance.actorId}</actors> + <subject>Task '#{taskInstance.name}' !</subject> + <text><![CDATA[Hey, +Don't forget about #{BaseTaskListURL}#{taskInstance.id} +Get going ! +---powered by JBoss jBPM---]]></text> + </mail-template> + +</mail-templates> Property changes on: projects/exception_framework/trunk/src/main/config/jbpm.mail.templates.xml ___________________________________________________________________ Name: svn:executable + * Added: projects/exception_framework/trunk/src/main/config/log4j.properties =================================================================== --- projects/exception_framework/trunk/src/main/config/log4j.properties (rev 0) +++ projects/exception_framework/trunk/src/main/config/log4j.properties 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,36 @@ +# Set root logger level to DEBUG and its only appender to CONSOLE. +log4j.rootLogger=DEBUG, CONSOLE + +# CONSOLE +log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender +log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout +log4j.appender.CONSOLE.layout.ConversionPattern=%d{HH:mm:ss,SSS} [%t] %-5p %C{1} : %m%n + +# LIMIT CATEGORIES: +log4j.logger.org.jbpm=ERROR +log4j.logger.org.jbpm.graph=ERROR + +# Hibernate debugging levels and their output +log4j.logger.org.hibernate=ERROR +#Log all SQL DML statements as they are executed +#log4j.logger.org.hibernate.SQL=DEBUG +#Log all JDBC parameters +#log4j.logger.org.hibernate.type=DEBUG +#Log all SQL DDL statements as they are executed +#log4j.logger.org.hibernate.tool.hbm2ddl=DEBUG +#Log the state of all entities (max 20 entities) associated with the session at flush time +#log4j.logger.org.hibernate.pretty=DEBUG +#Log all second-level cache activity +#log4j.logger.org.hibernate.cache=DEBUG +#Log transaction related activity +#log4j.logger.org.hibernate.transaction=DEBUG +#Log all JDBC resource acquisition +#log4j.logger.org.hibernate.jdbc=TRACE +#Log HQL and SQL ASTs and other information about query parsing +#log4j.logger.org.hibernate.hql.ast=DEBUG +#Log all JAAS authorization requests +#log4j.logger.org.hibernate.secure=DEBUG +#Log everything (a lot of information, but very useful for troubleshooting) +#log4j.logger.org.hibernate=DEBUG +#log4j.logger.org.hibernate.tools=DEBUG + Property changes on: projects/exception_framework/trunk/src/main/config/log4j.properties ___________________________________________________________________ Name: svn:executable + * Added: projects/exception_framework/trunk/src/main/config/version.info.xml =================================================================== --- projects/exception_framework/trunk/src/main/config/version.info.xml (rev 0) +++ projects/exception_framework/trunk/src/main/config/version.info.xml 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,21 @@ +<jbpm-version-info name="jBPM3" namespace="urn:jbpm.org:jpdl-3.2"> + + <classpathentry path="lib/jbpm-jpdl.jar" src="src/jbpm-jpdl-sources.jar" /> + <classpathentry path="lib/jbpm-identity.jar" src="src/jbpm-identity-sources.jar" /> + + <classpathentry path="lib/antlr.jar" /> + <classpathentry path="lib/asm.jar"/> + <classpathentry path="lib/bsh.jar"/> + <classpathentry path="lib/cglib.jar"/> + <classpathentry path="lib/commons-collections.jar"/> + <classpathentry path="lib/commons-logging.jar"/> + <classpathentry path="lib/dom4j.jar"/> + <classpathentry path="lib/hibernate.jar"/> + <classpathentry path="lib/hsqldb.jar"/> + <classpathentry path="lib/junit.jar"/> + <classpathentry path="lib/log4j.jar"/> + + <config path="config"/> + <examples path="examples" /> + +</jbpm-version-info> Property changes on: projects/exception_framework/trunk/src/main/config/version.info.xml ___________________________________________________________________ Name: svn:executable + * Added: projects/exception_framework/trunk/src/main/java/org/jboss/handler/AbstractExceptionActionHandler.java =================================================================== --- projects/exception_framework/trunk/src/main/java/org/jboss/handler/AbstractExceptionActionHandler.java (rev 0) +++ projects/exception_framework/trunk/src/main/java/org/jboss/handler/AbstractExceptionActionHandler.java 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,208 @@ +package org.jboss.handler; + +import java.security.AccessController; +import java.security.PrivilegedAction; + +import javax.transaction.Status; +import javax.transaction.Synchronization; + +import org.apache.commons.lang.StringUtils; +import org.apache.log4j.Logger; +import org.jboss.util.ThreadPoolSingleton; +import org.jbpm.JbpmConfiguration; +import org.jbpm.JbpmContext; +import org.jbpm.graph.def.ActionHandler; +import org.jbpm.graph.exe.ExecutionContext; +import org.jbpm.graph.exe.Token; +import org.jbpm.graph.node.State; +import org.jbpm.instantiation.ProcessClassLoader; +import org.jbpm.util.ClassLoaderUtil; + +/** + * Base class for ActionHandler which call services. + */ +public abstract class AbstractExceptionActionHandler implements ActionHandler { + /** Serial version UID. */ + private static final long serialVersionUID = 1L; + + public static final String EXCEPTION_ORIGINATING_NODE_NAME_KEY = "EXCEPTION_ORIGINATING_NODE_NAME"; + + private String transitionName; + + /** False means you are using our exception framework handling of exceptions. */ + private boolean useJbpmExceptionHandler = false; + + private boolean signalAfterException = false; + + protected final String getCurrentAction() { + return "action handling"; + } + + /** Logging facility. */ + private static final Logger LOGGER = Logger.getLogger(AbstractExceptionActionHandler.class); + + + public final void execute(ExecutionContext executionContext) throws Exception { + + getLogger().info("Start AbstractExceptionActionHanlder."); + + ExecutionContext.pushCurrentContext(executionContext); + try { + if (executionContext.getNode() instanceof State) { + // Asynchronous handling. + if (getLogger().isDebugEnabled()) { + getLogger().debug("Scheduling async job [" + getClass().getName() + "] for process instance " + executionContext.getProcessInstance().getId()); + } + + // Dig into Hibernate here to accomplish transaction isolation. + executionContext.getJbpmContext().getSession().getTransaction().registerSynchronization( + new ServiceRunner(executionContext.getToken().getId(), getClass().getName())); + } else { + try { + // Synchronous handling: Perform the action directly. + getLogger().debug("Performing action on Node with id: " + executionContext.getProcessInstance().getId()); + doPerformAction(executionContext); + } catch (Exception ex) { + getLogger().error("Handler threw exception.", ex); + getLogger().debug("Using jBPMExceptionHandler for exception caught on Node with id: " + executionContext.getProcessInstance().getId()); + executionContext.getNode().raiseException(ex, executionContext); + } + } + } catch (Exception ex) { + if (getLogger().isInfoEnabled()) { + getLogger().info(("Exception caught during AbstractExceptionActionHandling."), ex); + } + } finally { + ExecutionContext.popCurrentContext(executionContext); + } + + getLogger().info("Ended AbstractExceptionActionHanlder."); + } + + + /** + * Implement this method for processing a single node. + * + * @param executionContext An execution context. + * @throws Exception For all unexpected errors. + */ + public abstract void doPerformAction(ExecutionContext executionContext) throws Exception; + + /** + * Set this flag when it is required to have the process signalled 'normally' in case an exception is caught (and handled) + * within the asynchronous part of the handling. + * <p> + * The default behaviour is that no signalling takes place; this puts the responsibility of the progress of the process in the + * hands of the mechanism handling the exception. + * + * @param signal Whether signalling is to take place after exception handling. + */ + protected final void setSignalAfterException(final boolean signal) { + signalAfterException = signal; + } + + /** + * Set the transition to be taken for an asynchronous execution. + * + * @param transitionName The name of the transition. + */ + protected void setTransition(String transitionName) { + this.transitionName = transitionName; + } + + /** + * Set whether the 'standard' jBPM <exception-handler> construct in the + * process definition is to be used for the exception handling for an + * asynchronous execution. + * <p> + * The default behaviour for this class is to handle it implicitly and + * redirect the flow towards an exception handling node, which is required + * to be present in the definition (and its name in the context). + * + * @param useJbpmExceptionHandler + * Indicating whether (or not) to use the jBPM mechanism. By + * default this value is <code>false</code>. + */ + protected final void useJbpmExceptionHandler( + final boolean useJbpmExceptionHandler) { + this.useJbpmExceptionHandler = useJbpmExceptionHandler; + } + + + /** + * Inner class which performs the actual action handling for asynchronous + * State nodes. + */ + class ServiceRunner implements Runnable, Synchronization { + private long tokenId; + private String handlerClassName; + + public ServiceRunner(long tokenId, String handlerClassName) { + this.tokenId = tokenId; + this.handlerClassName = handlerClassName; + } + + /** {@inheritDoc} */ + public void run() { + JbpmContext jbpmCtx = JbpmConfiguration.getInstance().createJbpmContext(); + try { + // Get the token in which the process is waiting. + final Token token = jbpmCtx.getTokenForUpdate(tokenId); + ExecutionContext executionContext = new ExecutionContext(token); + + // Perform the action in the concrete subclass. + ExecutionContext.pushCurrentContext(executionContext); + AbstractExceptionActionHandler currentHandler = null; + boolean exceptionCaught = false; + try { + ClassLoader cl = AccessController.doPrivileged(new PrivilegedAction<ProcessClassLoader>() { + public ProcessClassLoader run() { + return new ProcessClassLoader(ClassLoaderUtil.class.getClassLoader(), token.getProcessInstance().getProcessDefinition()); + } + }); + currentHandler = (AbstractExceptionActionHandler) cl.loadClass( + handlerClassName).newInstance(); + currentHandler.doPerformAction(executionContext); + } catch (Exception ex) { + getLogger().error("Handler threw exception.", ex); + executionContext.getNode().raiseException(ex, executionContext); + exceptionCaught = true; + } finally { + ExecutionContext.popCurrentContext(executionContext); + } + + // Move the process along, if applicable. + if (!exceptionCaught || !useJbpmExceptionHandler || signalAfterException) { + if (!StringUtils.isBlank(transitionName) && executionContext.getNode().hasLeavingTransition(transitionName)) { + token.signal(transitionName); + } else { + // Use the default transition. + token.signal(); + } + } + } finally { + jbpmCtx.close(); + } + } + + /** Inherited method not used here. */ + public void beforeCompletion() { + // Not used here. + } + + public void afterCompletion(int status) { + if (getLogger().isDebugEnabled() + && status != Status.STATUS_COMMITTED && status != Status.STATUS_ROLLEDBACK) { + getLogger().debug("Attempting to start asynchronous action handling while tx status was " + status); + } + + // The original transaction is completed, a new one can be started. + ThreadPoolSingleton.INSTANCE.executeServiceCall(this); + } + } + + protected Logger getLogger() { + return LOGGER; + } + +} Added: projects/exception_framework/trunk/src/main/java/org/jboss/handler/DetermineExceptionHandlingHandler.java =================================================================== --- projects/exception_framework/trunk/src/main/java/org/jboss/handler/DetermineExceptionHandlingHandler.java (rev 0) +++ projects/exception_framework/trunk/src/main/java/org/jboss/handler/DetermineExceptionHandlingHandler.java 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,50 @@ +package org.jboss.handler; + +import org.apache.commons.lang.StringUtils; +import org.apache.log4j.Logger; +import org.jbpm.graph.exe.ExecutionContext; +import org.jbpm.graph.node.DecisionHandler; + +/** + * Handler for deciding whether it is applicable to automatically have the + * Exception throwing node retry its business. + */ +public class DetermineExceptionHandlingHandler implements DecisionHandler { + /** Serial version UID. */ + private static final long serialVersionUID = 1L; + + /** Logging facility. */ + private static final Logger LOGGER = Logger + .getLogger(DetermineExceptionHandlingHandler.class); + + private static final String DROPOUT_TRANSITION_NAME = "No"; + private static final String RETRY_TRANSITION_NAME = "Yes"; + + + protected Logger getLogger() { + return LOGGER; + } + + public String decide(ExecutionContext executionContext) throws Exception { + // TODO Auto-generated method stub + // check for our path of execution in exception handling. + String transition = null; + if (executionContext.getContextInstance().getVariable("take_exception_transtion") != null) { + getLogger().debug("Determined that context variable with name: " + + executionContext.getContextInstance().getVariable("take_exception_transtion") + + " exists!"); + transition = (String) executionContext.getContextInstance().getVariable("take_exception_transtion"); + } + + // TODO: Determine from configuration data whether the Exception that is + // handled here is applicable to be retried automatically. + + if ( StringUtils.isNotBlank(transition) && StringUtils.equals(transition, "retry")) { + getLogger().debug("Determine Exception Handling Handler choosing transition: " + RETRY_TRANSITION_NAME); + return RETRY_TRANSITION_NAME; + } + + getLogger().debug("Determine Exception Handling Handler choosing transition: " + DROPOUT_TRANSITION_NAME); + return DROPOUT_TRANSITION_NAME; + } +} Added: projects/exception_framework/trunk/src/main/java/org/jboss/handler/HumanTaskHandler.java =================================================================== --- projects/exception_framework/trunk/src/main/java/org/jboss/handler/HumanTaskHandler.java (rev 0) +++ projects/exception_framework/trunk/src/main/java/org/jboss/handler/HumanTaskHandler.java 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,51 @@ +package org.jboss.handler; + +import org.apache.log4j.Logger; +import org.jbpm.graph.def.Event; +import org.jbpm.graph.def.Node; +import org.jbpm.graph.exe.ExecutionContext; + +/** + * Handler for preparing before and following up after a manual human task. + */ +public class HumanTaskHandler extends AbstractExceptionActionHandler { + /** Serial version UID. */ + private static final long serialVersionUID = 1L; + + /** Logging facility. */ + private static final Logger LOGGER = Logger.getLogger(HumanTaskHandler.class); + + // Transition names. + private static final String RETRY_TRANSITION_NAME = "Retry"; + + public void doPerformAction(ExecutionContext executionContext) throws Exception { + if (Event.EVENTTYPE_NODE_LEAVE.equals(executionContext.getEvent().getEventType()) && RETRY_TRANSITION_NAME.equals(executionContext.getTransition().getName())) { + getLogger().debug("Have EVENTTYPE_NODE_LEAVE so updating retry transistions before going further!"); + getLogger().debug("Picked up event type " + executionContext.getEvent().getEventType() + " and transition name is " + executionContext.getTransition().getName()); + updateRetryTransition(executionContext); + } + } + + /** + * Point the retry transition to the Node from which the Exception + * originated. + * + * @param executionContext The current jBPM context. + */ + private void updateRetryTransition(ExecutionContext executionContext) { + String name = (String) executionContext.getVariable(EXCEPTION_ORIGINATING_NODE_NAME_KEY); + Node originatingNode = executionContext.getProcessDefinition().getNode(name); + getLogger().debug("updateRetryTranisition EXCEPTION_ORIGINATING_NODE_NAME_KEY is: " + name); + if (originatingNode == null) { + String msg = "No originating node available for retry after exception handling."; + LOGGER.error(msg); + throw new IllegalStateException(msg); + } + + executionContext.getNode().getLeavingTransition(RETRY_TRANSITION_NAME).setTo(originatingNode); + } + + protected Logger getLogger() { + return LOGGER; + } +} Added: projects/exception_framework/trunk/src/main/java/org/jboss/handler/RetryHandler.java =================================================================== --- projects/exception_framework/trunk/src/main/java/org/jboss/handler/RetryHandler.java (rev 0) +++ projects/exception_framework/trunk/src/main/java/org/jboss/handler/RetryHandler.java 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,47 @@ +package org.jboss.handler; + +import org.apache.log4j.Logger; +import org.jbpm.graph.def.Node; +import org.jbpm.graph.def.Transition; +import org.jbpm.graph.exe.ExecutionContext; + +/** + * Handler for retrying a node that threw an Exception before, after the waiting + * period configured for the specific situation. + */ +public class RetryHandler extends AbstractExceptionActionHandler { + /** Serial version UID. */ + private static final long serialVersionUID = 1L; + + /** Logging facility. */ + private static final Logger LOGGER = Logger.getLogger(RetryHandler.class); + + public void doPerformAction(ExecutionContext executionContext) throws Exception { + // TODO: Determine the waiting period from the configuration. + + // TODO: Wait the applicable period. + + // Check whether a leaving transition is available. + Transition transition = executionContext.getNode().getDefaultLeavingTransition(); + getLogger().debug("Default leaving transition from RetryHandler is: " + transition); + if (transition == null) { + // Create a transition. + transition = new Transition(); + executionContext.getNode().addLeavingTransition(transition); + getLogger().debug("Leaving transition from RetryHandler has been set to: " + transition); + } + // Set the transition to the originating node. + Node originatingNode = executionContext.getProcessDefinition().getNode(EXCEPTION_ORIGINATING_NODE_NAME_KEY); + if (originatingNode == null) { + String msg = "No originating node available for retry after exception handling."; + LOGGER.error(msg); + throw new IllegalStateException(msg); + } + getLogger().debug("Transition from RetryHandler is being set to: " + originatingNode); + transition.setTo(originatingNode); + } + + protected Logger getLogger() { + return LOGGER; + } +} Added: projects/exception_framework/trunk/src/main/java/org/jboss/handler/StartExceptionFrameworkHandler.java =================================================================== --- projects/exception_framework/trunk/src/main/java/org/jboss/handler/StartExceptionFrameworkHandler.java (rev 0) +++ projects/exception_framework/trunk/src/main/java/org/jboss/handler/StartExceptionFrameworkHandler.java 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,90 @@ +package org.jboss.handler; + +import java.util.List; + +import org.apache.log4j.Logger; +import org.jbpm.graph.def.ActionHandler; +import org.jbpm.graph.def.ProcessDefinition; +import org.jbpm.graph.exe.ExecutionContext; +import org.jbpm.graph.exe.ProcessInstance; + +public class StartExceptionFrameworkHandler implements ActionHandler { + + private static final long serialVersionUID = 1L; + + /** Context variable keys for storing exception information. */ + public static final String EXCEPTION_ORIGINATING_NODE_NAME_KEY = "EXCEPTION_ORIGINATING_NODE_NAME"; + public static final String EXCEPTION_ORIGINATING_PROCESS_NAME_KEY = "EXCEPTION_ORIGINATING_PROCESS_NAME"; + public static final String EXCEPTION_ORIGINATING_NODE_TRANSITION_LIST_KEY = "EXCEPTION_ORIGINATING_NODE_TRANSITION_LIST"; + public static final String EXCEPTION_ORIGINATING_PROCESS_ID_KEY = "EXCEPTION_ORIGINATING_PROCESS_ID"; + public static final String EXCEPTION_FRAMEWORK_PROCESS_ID_KEY = "EXCEPTION_FRAMEWORK_PROCESS_ID"; + + /** Exception framework process name. */ + public static final String EXCEPTION_FRAMEWORK_PROCESS_NAME_KEY = "Exception Framework"; + + /** Logging facility. */ + private static final Logger LOGGER = Logger.getLogger(StartExceptionFrameworkHandler.class); + + /** Holds our process instance. */ + private ProcessInstance processInstance; + + /** + * Handler starts the exception framework. + */ + public final void execute(ExecutionContext executionContext) throws Exception { + + getLogger().info("Start StartExceptionFrameworkHanlder."); + + try { + // get new instance of exception framework and start processing! + List<ProcessDefinition> listProcs = executionContext.getJbpmContext().getGraphSession().findAllProcessDefinitions(); + + if (getLogger().isDebugEnabled()) { + for (ProcessDefinition processDefinition : listProcs) { + getLogger().debug("Process definition is: " + processDefinition + " with version: " + processDefinition.getVersion() + "."); + } + } + processInstance = executionContext.getJbpmContext().newProcessInstance(EXCEPTION_FRAMEWORK_PROCESS_NAME_KEY); + if (getLogger().isDebugEnabled()) { + if (processInstance == null) { + getLogger().debug("Process instance of exception framework was not created."); + } + getLogger().debug("Passing the process instance of exception framework to be signaled."); + } + + // push the exception framework process id into the context. + executionContext.setVariable(EXCEPTION_FRAMEWORK_PROCESS_ID_KEY, processInstance.getRootToken().getId()); + + // push originating stuff. + processInstance.getContextInstance().setVariable(EXCEPTION_ORIGINATING_NODE_NAME_KEY, executionContext.getVariable(EXCEPTION_ORIGINATING_NODE_NAME_KEY)); + processInstance.getContextInstance().setVariable(EXCEPTION_ORIGINATING_PROCESS_NAME_KEY, executionContext.getVariable(EXCEPTION_ORIGINATING_PROCESS_NAME_KEY)); + processInstance.getContextInstance().setVariable(EXCEPTION_ORIGINATING_PROCESS_ID_KEY, executionContext.getVariable(EXCEPTION_ORIGINATING_PROCESS_ID_KEY)); + processInstance.getContextInstance().setVariable(EXCEPTION_ORIGINATING_NODE_TRANSITION_LIST_KEY, executionContext.getVariable(EXCEPTION_ORIGINATING_NODE_TRANSITION_LIST_KEY)); + + if (getLogger().isDebugEnabled()) { + getLogger().debug("Set variable " + EXCEPTION_ORIGINATING_NODE_NAME_KEY + " for process instance with value :" + executionContext.getVariable(EXCEPTION_ORIGINATING_NODE_NAME_KEY)); + getLogger().debug("Set variable " + EXCEPTION_ORIGINATING_PROCESS_NAME_KEY + " for process instance with value :" + executionContext.getVariable(EXCEPTION_ORIGINATING_PROCESS_NAME_KEY)); + getLogger().debug("Set variable " + EXCEPTION_ORIGINATING_PROCESS_ID_KEY + " for process instance with value :" + executionContext.getVariable(EXCEPTION_ORIGINATING_PROCESS_ID_KEY)); + getLogger().debug("Set variable " + EXCEPTION_ORIGINATING_NODE_TRANSITION_LIST_KEY + " for process instance with value :" + executionContext.getVariable(EXCEPTION_ORIGINATING_NODE_TRANSITION_LIST_KEY)); + } + + + processInstance.signal(); + } catch (Exception ex) { + if (getLogger().isInfoEnabled()) { + getLogger().info(("Exception caught during StartExceptionFrameworkHandler."), ex); + } + } + + getLogger().info("Ended StartExceptionFrameworkHandler."); + } + + protected String getCurrentAction() { + return "starting exception framework process"; + } + + protected Logger getLogger() { + return LOGGER; + } + +} Added: projects/exception_framework/trunk/src/main/java/org/jboss/handler/TriggerOriginatingProcessHandler.java =================================================================== --- projects/exception_framework/trunk/src/main/java/org/jboss/handler/TriggerOriginatingProcessHandler.java (rev 0) +++ projects/exception_framework/trunk/src/main/java/org/jboss/handler/TriggerOriginatingProcessHandler.java 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,92 @@ +package org.jboss.handler; + +import org.apache.commons.lang.StringUtils; +import org.apache.log4j.Logger; +import org.jbpm.JbpmConfiguration; +import org.jbpm.JbpmContext; +import org.jbpm.graph.def.ActionHandler; +import org.jbpm.graph.exe.ExecutionContext; +import org.jbpm.graph.exe.ProcessInstance; + +public class TriggerOriginatingProcessHandler implements ActionHandler { + + private static final long serialVersionUID = 1L; + + /** Context variable keys for storing exception information. */ + public static final String EXCEPTION_ORIGINATING_PROCESS_ID_KEY = "EXCEPTION_ORIGINATING_PROCESS_ID"; + public static final String EXCEPTION_ORIGINATING_NODE_LEAVE_TRANSITION_KEY = "EXCEPTION_ORIGINATING_NODE_LEAVE_TRANSITION"; + + private String transitionName; + + private ProcessInstance originatorProcInst; + + /** Logging facility. */ + private static final Logger LOGGER = Logger.getLogger(TriggerOriginatingProcessHandler.class); + + public final void execute(ExecutionContext executionContext) throws Exception { + getLogger().info("Start TriggerOriginatingProcessHandler."); + + try { + JbpmConfiguration jbpmConf = JbpmConfiguration.getInstance(); + JbpmContext jbpmCtx = jbpmConf.createJbpmContext(); + try { + // Get our process instance back. + originatorProcInst = jbpmCtx.getProcessInstance((Long) executionContext.getVariable(EXCEPTION_ORIGINATING_PROCESS_ID_KEY)); + + if (getLogger().isDebugEnabled()) { + if (originatorProcInst == null) { + getLogger().debug("Process instance of exception framework was not created."); + } + } + + // Determine from the context variable (see ContextConstants) which transition to take + // when we go back to the originating node. It should always be set to something, but we + // will take the default if it is null and log it as an error. + transitionName = (String) executionContext.getVariable(EXCEPTION_ORIGINATING_NODE_LEAVE_TRANSITION_KEY); + + if (StringUtils.isBlank(transitionName)) { + // Leave the node through the default transition, nothing to do just log this as an error as + // should never have to happen. + if (getLogger().isDebugEnabled()) { + getLogger().debug("Leaving transition not set in the context, leaving over the default transition."); + } + } else { + // Leave the node through the given transition we need to get out of the context variable if it exists, + // so checking it. + if (originatorProcInst.getRootToken().getNode().hasLeavingTransition(transitionName)) { + if (getLogger().isDebugEnabled()) { + getLogger().debug("Leaving node over the given transition " + transitionName); + } + } else { + // given non-existing transition, take default and log error. + getLogger().error("Leaving transition not set in the context, leaving over the default transition."); + transitionName = null; + } + } + + if (StringUtils.isBlank(transitionName)) { + originatorProcInst.getRootToken().signal(); + } else { + originatorProcInst.getRootToken().signal(transitionName); + } + executionContext.leaveNode(); + } finally { + jbpmCtx.close(); + } + } catch (Exception ex) { + if (getLogger().isInfoEnabled()) { + getLogger().info(("Exception caught during TriggerOriginatingProcessHandler."), ex); + } + } + getLogger().info("Ended TriggerOriginatingProcessHandler."); + } + + + protected String getCurrentAction() { + return "signaling originating process"; + } + + protected Logger getLogger() { + return LOGGER; + } +} Added: projects/exception_framework/trunk/src/main/java/org/jboss/util/ThreadPoolSingleton.java =================================================================== --- projects/exception_framework/trunk/src/main/java/org/jboss/util/ThreadPoolSingleton.java (rev 0) +++ projects/exception_framework/trunk/src/main/java/org/jboss/util/ThreadPoolSingleton.java 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,78 @@ +package org.jboss.util; + +import java.lang.Thread.UncaughtExceptionHandler; +import java.util.concurrent.Executor; +import java.util.concurrent.LinkedBlockingQueue; +import java.util.concurrent.RejectedExecutionException; +import java.util.concurrent.RejectedExecutionHandler; +import java.util.concurrent.ThreadPoolExecutor; +import java.util.concurrent.TimeUnit; + +import org.apache.log4j.Logger; + +/** + * Ensures this is a singleton implementation of the ThreadPool for service calls. + */ +public enum ThreadPoolSingleton { + /** The Threadpool singleton instance. */ + INSTANCE; + + private static final Logger LOGGER = Logger.getLogger(ThreadPoolSingleton.class); + + private final Integer numberThreads = 10; + private Executor exec = new HandleableThreadPoolExecutor(); + + private UncaughtExceptionHandler handler; + + /** + * This is what we do! + * + * @param command + * The runnable command. + */ + public void executeServiceCall(Runnable command) { + exec.execute(command); + } + + /** + * @param ueh + * A handler that is going to catch the uncaught exceptions instead of the default handler (e.g. for testing + * purposes). + */ + public void setUncaughtExceptionHandler(UncaughtExceptionHandler ueh) { + handler = ueh; + } + + /** + * ThreadPoolExecutor that allows for setting an <code>UncaughtExceptionHandler</code> to each thread that is used to execute a + * given <code>Runnable</code>. + */ + private class HandleableThreadPoolExecutor extends ThreadPoolExecutor { + /** Default constructor that creates a 'fixed thread pool'. */ + HandleableThreadPoolExecutor() { + super(numberThreads, numberThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); + setRejectedExecutionHandler(new DefaultRejectedExecutionHandler()); + } + + /** {@inheritDoc} */ + @Override + protected void beforeExecute(Thread t, Runnable r) { + if (LOGGER.isDebugEnabled()) { + LOGGER.debug("Starting task " + r + " in thread " + t); + } + if (handler != null) { + t.setUncaughtExceptionHandler(handler); + } + } + } + + /** + * Default implementation for the <code>RejectedExecutionHandler</code>. + */ + private static class DefaultRejectedExecutionHandler implements RejectedExecutionHandler { + public void rejectedExecution(Runnable r, ThreadPoolExecutor tpe) { + LOGGER.error(tpe + " unable to handle task " + r); + throw new RejectedExecutionException(); + } + } +} Added: projects/exception_framework/trunk/src/main/jpdl/process/gpd.xml =================================================================== --- projects/exception_framework/trunk/src/main/jpdl/process/gpd.xml (rev 0) +++ projects/exception_framework/trunk/src/main/jpdl/process/gpd.xml 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,41 @@ +<?xml version="1.0" encoding="UTF-8"?> + +<root-container name="Exception Framework" width="1315" height="512"> + <node name="start" x="188" y="18" width="140" height="40"> + <edge> + <label x="5" y="-10"/> + </edge> + </node> + <node name="Determine Exception Handling" x="150" y="107" width="225" height="36"> + <edge> + <label x="5" y="-10"/> + </edge> + <edge> + <label x="5" y="-10"/> + </edge> + </node> + <node name="Human Task" x="55" y="186" width="132" height="36"> + <edge> + <label x="5" y="-10"/> + </edge> + </node> + <node name="Retry" x="336" y="190" width="132" height="36"> + <edge> + <label x="5" y="-10"/> + </edge> + </node> + <node name="Trigger Originating Process" x="142" y="279" width="247" height="36"> + <edge> + <label x="5" y="-10"/> + </edge> + </node> + <node name="end" x="181" y="364" width="140" height="40"/> + <deployment serverName="" serverPort="" serverDeployer="/gpd-deployer/upload"> + <classesAndResources/> + <filesAndFolders> + <element value="/exception_framework/src/main/jpdl/process/gpd.xml"/> + <element value="/exception_framework/src/main/jpdl/process/processdefinition.xml"/> + <element value="/exception_framework/src/main/jpdl/process/processimage.jpg"/> + </filesAndFolders> + </deployment> +</root-container> Added: projects/exception_framework/trunk/src/main/jpdl/process/processdefinition.xml =================================================================== --- projects/exception_framework/trunk/src/main/jpdl/process/processdefinition.xml (rev 0) +++ projects/exception_framework/trunk/src/main/jpdl/process/processdefinition.xml 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,42 @@ +<?xml version="1.0" encoding="UTF-8"?> + +<process-definition xmlns="urn:jbpm.org:jpdl-3.1" name="Exception Framework"> + + <start-state name="start"> + <transition to="Determine Exception Handling" /> + </start-state> + + <decision name="Determine Exception Handling"> + <handler class="org.jboss.handler.DetermineExceptionHandlingHandler" /> + <transition to="Human Task" name="No" /> + <transition to="Retry" name="Yes" /> + </decision> + + <task-node name="Human Task"> + <task name="Technical dropout"> + <assignment actor-id="EXPERT" /> + </task> + <event type="node-enter"> + <action class="org.jboss.handler.HumanTaskHandler"></action> + </event> + <event type="node-leave"> + <action class="org.jboss.handler.HumanTaskHandler" /> + </event> + <transition to="Trigger Originating Process"></transition> + </task-node> + + <state name="Retry"> + <event type="node-enter"> + <action class="org.jboss.handler.RetryHandler" /> + </event> + <transition to="Trigger Originating Process" /> + </state> + + <node name="Trigger Originating Process"> + <action class="org.jboss.handler.TriggerOriginatingProcessHandler" /> + <transition to="end" /> + </node> + + <end-state name="end" /> + +</process-definition> \ No newline at end of file Added: projects/exception_framework/trunk/src/main/jpdl/process/processimage.jpg =================================================================== (Binary files differ) Property changes on: projects/exception_framework/trunk/src/main/jpdl/process/processimage.jpg ___________________________________________________________________ Name: svn:mime-type + application/octet-stream Added: projects/exception_framework/trunk/src/test/java/org/jboss/handler/ExceptionThrowingHandler.java =================================================================== --- projects/exception_framework/trunk/src/test/java/org/jboss/handler/ExceptionThrowingHandler.java (rev 0) +++ projects/exception_framework/trunk/src/test/java/org/jboss/handler/ExceptionThrowingHandler.java 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,200 @@ +package org.jboss.handler; + +import java.util.Date; +import java.util.Iterator; + +import org.apache.commons.lang.StringUtils; +import org.apache.log4j.Logger; +import org.jbpm.graph.def.Action; +import org.jbpm.graph.def.ActionHandler; +import org.jbpm.graph.def.Transition; +import org.jbpm.graph.exe.ExecutionContext; +import org.jbpm.instantiation.Delegation; +import org.jbpm.job.ExecuteActionJob; +import org.jbpm.msg.MessageService; +import org.jbpm.svc.ServiceFactory; +import org.jbpm.svc.Services; + +public class ExceptionThrowingHandler implements ActionHandler { + + private static final long serialVersionUID = 1L; + + /** Context variable keys for storing exception information. */ + public static final String EXCEPTION_ORIGINATING_NODE_NAME_KEY = "EXCEPTION_ORIGINATING_NODE_NAME"; + public static final String EXCEPTION_ORIGINATING_PROCESS_NAME_KEY = "EXCEPTION_ORIGINATING_PROCESS_NAME"; + public static final String EXCEPTION_ORIGINATING_NODE_TRANSITION_LIST_KEY = "EXCEPTION_ORIGINATING_NODE_TRANSITION_LIST"; + public static final String EXCEPTION_ORIGINATING_PROCESS_ID_KEY = "EXCEPTION_ORIGINATING_PROCESS_ID"; + + private boolean leaveNode = true; + + private String transitionName; + + private static String retryTransitionName = "Retry"; + + /** Set to false to use custom exception framework. */ + private boolean useJbpmExceptionHandler = false; + + /** Conditional error throwing variable. **/ + private static final String EXCEPTION_THROWN = "EXCEPTION_THROWN"; + + /** Logging facility. */ + private static final Logger LOGGER = Logger.getLogger(ExceptionThrowingHandler.class); + + + /** + * Our execution method where the work is done! + * + * @param executionContext Current execution context. + */ + public void execute(ExecutionContext executionContext) throws Exception { + + if (getLogger().isDebugEnabled()) { + getLogger().debug("Starting jBPM custom exception framework."); + } + + ExecutionContext.pushCurrentContext(executionContext); + + try { + try { + // Perform the action. + if (getLogger().isDebugEnabled()) { + getLogger().debug("Performing action for process instance with id: " + executionContext.getProcessInstance().getId()); + } + doPerformAction(executionContext); + + if (leaveNode) { + // Leave the node through the given transition. + if (getLogger().isDebugEnabled()) { + getLogger().debug("Leaving node over " + + (StringUtils.isBlank(transitionName) ? "default transition." : "transition: " + + transitionName)); + } + + // When leaving the node we can either have set a transition to take while in the doPerformAction via the + // setTransition method or leave it to the default transition, here we decide what has happened. + if (StringUtils.isBlank(transitionName)) { + executionContext.getNode().leave(executionContext); + } else { + executionContext.getNode().leave(executionContext, transitionName); + } + } + } catch (Exception ex) { + if (useJbpmExceptionHandler) { + if (getLogger().isDebugEnabled()) { + getLogger().debug( + "Using jBPMExceptionHandler for exception caught in process instance with id: " + + executionContext.getProcessInstance().getId()); + } + executionContext.getNode().raiseException(ex, executionContext); + } else { + if (getLogger().isDebugEnabled()) { + getLogger() + .debug( + "Using handleException (custom) for exception caught in process instance with id: " + + executionContext.getProcessInstance().getId() + + " and pushing exception to context with setException."); + } + executionContext.setException(ex); + + handleException(executionContext); + if (getLogger().isDebugEnabled()) { + getLogger().debug("Exception passed to framework, now we wait."); + } + } + } + } catch (Exception ex) { + if (getLogger().isInfoEnabled()) { + getLogger().info(("Exception caught during jBPM custom framework execution"), ex); + } + } finally { + ExecutionContext.popCurrentContext(executionContext); + } + } + + + /** + * This method is used to handle exceptions. + * + * @param executionContext Current execution context. + */ + private void handleException(ExecutionContext executionContext) { + getLogger().info("Start exception handling for custom jBPM exception framework."); + + // Save the current node in the context to make a retry possible. + executionContext.setVariable(EXCEPTION_ORIGINATING_NODE_NAME_KEY, executionContext.getNode().getName()); + executionContext.setVariable(EXCEPTION_ORIGINATING_PROCESS_NAME_KEY, executionContext.getProcessDefinition().getName()); + executionContext.setVariable(EXCEPTION_ORIGINATING_PROCESS_ID_KEY, executionContext.getProcessInstance().getId()); + + // Also save the transitions that we will want to provide a choice of (all outgoing transitions + // plus a retry transition that loops back to the same node. First we add the loopback transition + // to the existing list (note, adding to back of list, do not want it to become the default!). + Transition retryTransition = new Transition(); + retryTransition.setName(retryTransitionName); + retryTransition.setTo(executionContext.getNode()); + executionContext.getNode().addLeavingTransition(retryTransition); + executionContext.setVariable(EXCEPTION_ORIGINATING_NODE_TRANSITION_LIST_KEY, executionContext.getNode().getLeavingTransitions()); + + if (getLogger().isDebugEnabled()) { + getLogger().debug("The EXCEPTION_ORIGINATING_NODE_NAME_KEY is set to: " + executionContext.getNode().getName()); + getLogger().debug("The EXCEPTION_ORIGINATING_PROCESS_NAME_KEY is set to: " + executionContext.getProcessDefinition().getName()); + getLogger().debug("The EXCEPTION_ORIGINATING_PROCESS_ID_KEY is set to: " + executionContext.getProcessInstance().getId()); + getLogger().debug("The following transitions have been pushed into the context: "); + int i = 0; + for (Iterator iterator = executionContext.getNode().getLeavingTransitions().iterator(); iterator.hasNext();) { + Transition transition = (Transition) iterator.next(); + getLogger().debug("Transition " + i + " called " + transition.getName()); + i++; + } + } + + // Pass the context off to the exception framework process. + ServiceFactory serviceFactory = executionContext.getJbpmContext().getServiceFactory(Services.SERVICENAME_MESSAGE); + if (serviceFactory != null) { + MessageService messageService = (MessageService) serviceFactory.openService(); + Action action = new Action(new Delegation(StartExceptionFrameworkHandler.class.getName())); + ExecuteActionJob job = new ExecuteActionJob(executionContext.getToken()); + job.setAction(action); + job.setDueDate(new Date()); + + // have to explicitly save the action context. + executionContext.getJbpmContext().getSession().saveOrUpdate(action); + messageService.send(job); + + if (getLogger().isDebugEnabled()) { + getLogger().debug("Scheduled job with jobExecuter and waiting for it to run..."); + } + } + + getLogger().info("Ended exception handling for jBPM custom exception framework."); + } + + /** + * The action for this handler with the sole purpose of throwing an exception. + * + * @param executionContext Current execution context. + * @throws Exception + */ + public void doPerformAction(ExecutionContext executionContext) throws Exception { + + // ensuring that the exception is thrown only once. + if (StringUtils.isEmpty((String) executionContext.getVariable(EXCEPTION_THROWN))) { + // mark the exception as being thrown once and only once! + if (getLogger().isDebugEnabled()) { + LOGGER.debug("ExceptionThrowningHandler ==> throwing in the kitchen sink now..."); + } + + executionContext.setVariable(EXCEPTION_THROWN, "kitchen_sink"); + throw new IllegalStateException("Creating a problem."); + } + + // reset the error variable. + executionContext.setVariable(EXCEPTION_THROWN, null); + } + + /** The logger. */ + protected Logger getLogger() { + return LOGGER; + + } + +} Added: projects/exception_framework/trunk/src/test/java/org/jboss/test/TestForNodeExceptionHandling.java =================================================================== --- projects/exception_framework/trunk/src/test/java/org/jboss/test/TestForNodeExceptionHandling.java (rev 0) +++ projects/exception_framework/trunk/src/test/java/org/jboss/test/TestForNodeExceptionHandling.java 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,239 @@ +package org.jboss.test; + +import static org.hamcrest.CoreMatchers.is; +import static org.hamcrest.CoreMatchers.not; +import static org.hamcrest.CoreMatchers.nullValue; +import static org.junit.Assert.assertThat; +import static org.junit.Assert.fail; + +import java.util.Collection; +import java.util.List; +import java.util.Set; + +import org.apache.commons.collections.CollectionUtils; +import org.apache.log4j.Appender; +import org.apache.log4j.BasicConfigurator; +import org.apache.log4j.Level; +import org.apache.log4j.Logger; +import org.jboss.util.ProcessDefinitionReference; +import org.jbpm.JbpmConfiguration; +import org.jbpm.JbpmContext; +import org.jbpm.db.GraphSession; +import org.jbpm.graph.def.ProcessDefinition; +import org.jbpm.graph.exe.ProcessInstance; +import org.jbpm.taskmgmt.exe.TaskInstance; +import org.junit.AfterClass; +import org.junit.BeforeClass; +import org.junit.Test; + +/** + * Tests for the Abstract Action Handler. + */ +public class TestForNodeExceptionHandling { + + /** The global jBPM configuration. */ + private static JbpmConfiguration jbpmConf = JbpmConfiguration.getInstance(); + + /** Variables for Tasks. */ + private static final String ACTOR_ID = "EXPERT"; + private static final String TASK_NAME = "Technical dropout"; + private static final Set<String> POOLED_ACTORS = null; + private static final String SWIMLANE = null; + + public static final String ORIGINATING_PROCESS_NAME = "Originator Process"; + public static final String EXCEPTION_FRAMEWORK_PROCESS_NAME = "Exception Framework"; + + /** + * Fix the standard logging setup to work better within the IDE console, + * just comment out to use and COMMENT OUT BEFORE CHECKIN. + */ + @BeforeClass + public static final void oneTimeSetupExceptionFrameworkTesting() { + // Turn on for logging in console to be within my IDE window size. + //((PatternLayout) ((Appender) Logger.getRootLogger().getAllAppenders().nextElement()).getLayout()).setConversionPattern("%r [%t] %p %c %x -%n%n %m%n%n"); + + + // Start the JobExecutor for async continuations within the test environment. + jbpmConf.startJobExecutor(); + + // Initialize logging. + BasicConfigurator.configure(); + // - Remove the superfluous appender. + Logger.getRootLogger().removeAppender((Appender) Logger.getRootLogger().getAllAppenders().nextElement()); + // Adjust levels: + Logger.getRootLogger().setLevel(Level.ERROR); + Logger.getLogger("org.jboss").setLevel(Level.DEBUG); + Logger.getLogger("org.jbpm.graph").setLevel(Level.DEBUG); + + // Deploy my exception framework too. + try { + deployExceptionFramework(); + } catch (Exception e) { + fail(e.getMessage()); + } + } + + /** + * Called once after all test runs, stops the JobExecutor. + * + * @throws Exception When something unexpected goes wrong. + */ + @AfterClass + public static final void oneTimeTearDown() throws Exception { + // End the JobExecutor thread. + jbpmConf.getJobExecutor().stop(); + } + + /** + * The main test we want to run here to throw an exception in the Node of our + * test process and handle it through our Exception Framework. + * + * @throws Exception + */ + @Test + public void testRun() throws Exception { + // deploy process first. + JbpmContext jbpmCtx = jbpmConf.createJbpmContext(); + try { + // Create an instance of the jBPM process. + ProcessDefinition procDef = getTestProcess().parseAndDeployProcess(); + ProcessInstance procInst = new ProcessInstance(procDef); + jbpmCtx.save(procInst); + } finally { + // Close the transaction. + jbpmCtx.close(); + } + + // signal process to start. + jbpmCtx = jbpmConf.createJbpmContext(); + try { + long processInstanceId = getProcessId(ORIGINATING_PROCESS_NAME); + ProcessInstance procInst = jbpmCtx.getProcessInstance(processInstanceId); + assertThat("No exception process instance returned.", procInst, is(not(nullValue()))); + procInst.signal(); + } finally { + jbpmCtx.close(); + } + + Thread.sleep(5000); + + // In Human Task and need to end which will cause the flow to signal back + // to the originating process. + endTask(); + + // Test that originating process is in end state. + jbpmCtx = jbpmConf.createJbpmContext(); + try { + long processInstanceId = getProcessId(ORIGINATING_PROCESS_NAME); + ProcessInstance procInst = jbpmCtx.getProcessInstance(processInstanceId); + assertThat("No exception process instance returned.", procInst, is(not(nullValue()))); + assertThat("Exception process not ended.", procInst.hasEnded(), is(true)); + } finally { + jbpmCtx.close(); + } + + // Test that it is in end state now for exception framework. + jbpmCtx = jbpmConf.createJbpmContext(); + try { + long processInstanceId = getProcessId(EXCEPTION_FRAMEWORK_PROCESS_NAME); + ProcessInstance procInst = jbpmCtx.getProcessInstance(processInstanceId); + assertThat("No exception process instance returned.", procInst, is(not(nullValue()))); + assertThat("Exception process in unexpected state.", procInst.hasEnded(), is(true)); + } finally { + jbpmCtx.close(); + } + } + + /** + * Gives you the test process definition. + */ + protected ProcessDefinitionReference getTestProcess() throws Exception { + String testProcDef = "<process-definition xmlns=\"urn:jbpm.org:jpdl-3.1\" name=\"" + ORIGINATING_PROCESS_NAME + "\">" + + "<start-state name=\"start\">" + + "<transition to=\"node1\" />" + + "</start-state>" + + "<node name=\"node1\" async=\"true\">" + + "<action class=\"org.jboss.handler.ExceptionThrowingHandler\" />" + + "<transition to=\"end\" name=\"node_to_end\" />" + + "</node>" + + "<end-state name=\"end\" />" + + "</process-definition>"; + return new ProcessDefinitionReference(testProcDef); + } + + private static void deployExceptionFramework() throws Exception { + // Open the transaction. + JbpmContext jbpmCtx = jbpmConf.createJbpmContext(); + try { + // Create an instance of the jBPM exception framework process. + String frameworkXml = "process/processdefinition.xml"; + ProcessDefinition procDef = ProcessDefinition.parseXmlResource(frameworkXml); + jbpmCtx.deployProcessDefinition(procDef); + } finally { + // Close the transaction. + jbpmCtx.close(); + } + } + + private void endTask() { + // Open the transaction. + JbpmContext jbpmCtx = jbpmConf.createJbpmContext(); + try { + long processInstanceId = getProcessId(EXCEPTION_FRAMEWORK_PROCESS_NAME); + ProcessInstance procInst = jbpmCtx.getProcessInstance(processInstanceId); + assertThat("No exception process instance returned.", procInst, is(not(nullValue()))); + + Collection<TaskInstance> taskInsts = procInst.getTaskMgmtInstance().getUnfinishedTasks(procInst.getRootToken()); + assertThat("No task instances found.", taskInsts, is(not(nullValue()))); + + TaskInstance taskInst = getIndicatedTaskInstance(taskInsts, ACTOR_ID, TASK_NAME, POOLED_ACTORS, SWIMLANE); + if (taskInst != null) { + // End the task instance. + taskInst.end(); + } + } finally { + // Tear down the pojo persistence context. + jbpmCtx.close(); + } + } + + + private long getProcessId (String processName) { + long procId; + + // Open the transaction. + JbpmContext jbpmCtx = jbpmConf.createJbpmContext(); + try { + // Get our process instance back. + GraphSession graphSession = jbpmCtx.getGraphSession(); + ProcessDefinition processDefinition = graphSession.findLatestProcessDefinition(processName); + assertThat("No process definition found.", processDefinition, is(not(nullValue()))); + + // Now, we search for all process instances of this process definition. + List processInstances = graphSession.findProcessInstances(processDefinition.getId()); + ProcessInstance procInst = (ProcessInstance) processInstances.get(0); + procId = procInst.getId(); + } finally { + // Tear down the pojo persistence context. + jbpmCtx.close(); + } + + return procId; + } + + private TaskInstance getIndicatedTaskInstance(Collection<TaskInstance> taskInsts, final String actorId, final String taskName, + final Set<String> pooledActors, final String swimlane) { + TaskInstance indicated = null; + for (TaskInstance taskInst : taskInsts) { + if ((actorId == null || actorId.equals(taskInst.getActorId())) + && (taskName == null || taskName.equals(taskInst.getTask().getName())) + && (pooledActors == null || CollectionUtils.isSubCollection(pooledActors, taskInst.getPooledActors())) + && (swimlane == null || swimlane.equals(taskInst.getSwimlaneInstance().getName()))) { + indicated = taskInst; + break; + } + } + return indicated; + } + +} Added: projects/exception_framework/trunk/src/test/java/org/jboss/util/ProcessDefinitionReference.java =================================================================== --- projects/exception_framework/trunk/src/test/java/org/jboss/util/ProcessDefinitionReference.java (rev 0) +++ projects/exception_framework/trunk/src/test/java/org/jboss/util/ProcessDefinitionReference.java 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,88 @@ +package org.jboss.util; + +import java.io.IOException; +import java.util.ArrayList; +import java.util.List; + +import org.apache.log4j.Logger; +import org.jbpm.JbpmConfiguration; +import org.jbpm.graph.def.ProcessDefinition; + +/** + * Container for a process definition reference, with the possibility to include + * a list of these containers for the subprocesses. + */ +public class ProcessDefinitionReference { + private static final Logger LOGGER = Logger.getLogger(ProcessDefinitionReference.class); + + private static final JbpmConfiguration JBPM_CONF = JbpmConfiguration.getInstance(); + + /** The String containing an XML process definition or the name of a parsable resource. */ + private String procDefString; + + /** The list of subprocesses. */ + private List<ProcessDefinitionReference> subprocs = new ArrayList<ProcessDefinitionReference>(); + + /** + * Constructor for process definition <code>String</code>s. + * + * @param procDefString + * The process definition, in one of the following formats: + * <ul> + * <li>An XML format string containing the definition. + * <li>The file pathname for the process archive resource (ending + * in '.par') containing the definition. + * <li>The file pathname for the resource containing the + * definition. + * </ul> + */ + public ProcessDefinitionReference(final String procDefString) { + this.procDefString = procDefString; + } + + /** + * Chainable convenience method for adding subprocesses. + * + * @param ref The reference object for the subprocess definition to be added. + * @return A reference to the process to which the subprocess was just added. + */ + public ProcessDefinitionReference addSubproc(ProcessDefinitionReference ref) { + subprocs.add(ref); + return this; + } + + /** + * @return The reference to the top-level process definition, which is + * deployed along with all of its nested subprocesses. + */ + public ProcessDefinition parseAndDeployProcess() { + // First do the subprocesses (recursively). + for (ProcessDefinitionReference subProcRef : subprocs) { + subProcRef.parseAndDeployProcess(); + } + + // Then do this process itself. + // - Parse. + ProcessDefinition procDef = null; + if (procDefString.endsWith("</process-definition>")) { + // It's a process definition XML String. + procDef = ProcessDefinition.parseXmlString(procDefString); + } else if (procDefString.endsWith(".par")) { + // It's a process archive. + try { + procDef = ProcessDefinition.parseParResource(procDefString); + } catch (IOException ioEx) { + LOGGER.error("Cannot parse .par file as a resource.", ioEx); + } + } else { + // Assume it's a definition in a resource on the classpath. + procDef = ProcessDefinition.parseXmlResource(procDefString); + } + // - Deploy. + if (procDef != null) { + JBPM_CONF.getCurrentJbpmContext().deployProcessDefinition(procDef); + } + + return procDef; + } +} Added: projects/exception_framework/trunk/src/test/java/org/jboss/util/TaskCallback.java =================================================================== --- projects/exception_framework/trunk/src/test/java/org/jboss/util/TaskCallback.java (rev 0) +++ projects/exception_framework/trunk/src/test/java/org/jboss/util/TaskCallback.java 2010-04-20 18:27:47 UTC (rev 6264) @@ -0,0 +1,15 @@ +package org.jboss.util; + +import org.jbpm.graph.exe.ExecutionContext; + +/** Interface for implementation of Task performing during tests. */ +public interface TaskCallback { + /** + * Called to allow for performing work to mimic a manual task. + * + * @param executionContext + * The jBPM execution context for the transaction in which the + * work can be done. + */ + void performTask(ExecutionContext executionContext); +}