Hi J!
Here is the code for the custom fork. The code is a little bit too tailored to
our specific needs and we are still thinking how to do it better. I hope it
helps. You comments are appreciated.
Thank you,
Mark
| import java.util.LinkedList;
| import java.util.List;
|
| import org.jbpm.graph.def.ActionHandler;
| import org.jbpm.graph.def.Node;
| import org.jbpm.graph.def.Transition;
| import org.jbpm.graph.exe.ExecutionContext;
| import org.jbpm.graph.exe.Token;
|
| public class MultiplexorAction implements ActionHandler {
|
| private static final long serialVersionUID = -5530634487359948748L;
|
| //
| // Name of the process variable that contains the list of items
| //
| private String listVariable;
|
| //
| // Name of the process variable that will contain the item -
| // output for each new token
| //
| protected String as;
|
| private List list;
| protected static final String FOREACH_PREFIX = "ea";
|
| /**
| * Create a new child token for each item in list.
| *
| * @param executionContext
| * @throws Exception
| */
| public void execute(final ExecutionContext executionContext)
| throws Exception {
| final Token rootToken = executionContext.getToken();
| final Node node = executionContext.getNode();
|
| initializeList(executionContext, rootToken);
|
| final List argSets = new LinkedList();
| Transition rootTransition = null;
| Transition defaultTransition = null;
|
| //
| // First, create a new token and execution context for each
item in
| // list.
| //
| for (int i = 0; i < node.getLeavingTransitions().size(); i++) {
| final Transition transition = (Transition) node
| .getLeavingTransitions().get(i);
|
| //
| // A transition that starts from the words "root exit"
| // will be reserved for the original (root) token
| // that came to the multiplexor node
| //
| if (transition.getName() != null
| &&
transition.getName().toLowerCase().startsWith(
| "root exit")) {
| rootTransition = transition;
| continue;
| }
|
| //
| // A transition that starts from the words "default
exit"
| // will be reserved for the new token
| // that will be the exact copy of the original (root
token)
| //
| if (transition.getName() != null
| &&
transition.getName().toLowerCase().startsWith(
| "default exit")) {
| defaultTransition = transition;
| continue;
| }
|
| for (int j = 0; list != null && j < list.size(); j++) {
| final Object item = list.get(j);
|
| // generate a name for the new child token
| String tokenName = FOREACH_PREFIX + "." +
node.getId() + "."
| + j;
|
| // generate and save new token
| final Token newToken = new Token(rootToken,
tokenName);
| newToken.setTerminationImplicit(true);
|
executionContext.getJbpmContext().getSession().save(newToken);
|
| // create token variable from the list item
| final ExecutionContext newExecutionContext =
new ExecutionContext(
| newToken);
|
newExecutionContext.getContextInstance().createVariable(as,
| item, newToken);
|
| // remember this new token with its context so
we can
| // launch it later
| argSets.add(new Object[] { newExecutionContext,
transition });
| }
| }
|
| // Delete the original list variable.
| // This step could be done in the process itself
| // since someone may still want reuse this list
|
executionContext.getContextInstance().deleteVariable(listVariable);
|
| //
| // Now, let each new tokens leave the node.
| //
| for (int i = 0; i < argSets.size(); i++) {
| final Object[] args = (Object[]) argSets.get(i);
| node.leave((ExecutionContext) args[0], (Transition)
args[1]);
| }
|
| //
| // Generate the token for the default node and launch it
| //
| if (defaultTransition != null) {
| String tokenName = "df." + node.getId();
|
| final Token newToken = new Token(rootToken, tokenName);
| newToken.setTerminationImplicit(true);
|
executionContext.getJbpmContext().getSession().save(newToken);
| final ExecutionContext newExecutionContext = new
ExecutionContext(
| newToken);
| node.leave(newExecutionContext, defaultTransition);
| }
|
| //
| // Send the original root token that came to this node with the
list
| // to the root exit transition. The assumed case is that this
| // original token would come to the join node to wait for all
its
| // children generated above.
| //
| // If the original root token is routed to some business nodes
| // then after all its children would come
| // to the join node, it will effectively terminate this original
| // token. This behavior would leave the only option for this
| // root token: to be routed to the join node to wait for all
| // its children to complete.
| //
| if (rootTransition != null) {
| node.leave(executionContext, rootTransition);
| }
| }
|
| public List getList() {
| return list;
| }
|
| public void setList(final List list) {
| this.list = list;
| }
|
| public String getAs() {
| return as;
| }
|
| public void setAs(final String as) {
| this.as = as;
| }
|
| public String getListVariable() {
| return listVariable;
| }
|
| public void setListVariable(final String listVariable) {
| this.listVariable = listVariable;
| }
|
| protected void initializeList(final ExecutionContext executionContext,
| Token token) {
| if (listVariable != null) {
| list = (List)
executionContext.getContextInstance().getVariable(
| listVariable, token);
| if (list == null)
| list = (List)
executionContext.getContextInstance()
| .getVariable(listVariable);
| }
| }
| }
|
|
|
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4072812#4072812
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4072812
_______________________________________________
jboss-user mailing list
[email protected]
https://lists.jboss.org/mailman/listinfo/jboss-user
