From 5a779c885814245edfaf170569a97c503aecd67f Mon Sep 17 00:00:00 2001
From: Janne Valkealahti <janne.valkealahti@gmail.com>
Date: Wed, 28 Sep 2016 15:40:26 +0100
Subject: [PATCH] Backport: Refactor join handling

- Backporting #235 #237
- Refactor how join is handled
- Add new StateListener for listening entry/exit per State.
- Transition is now passed to next guy from a join state.
- A lot of changes in core machine/factory/executor to support
  this new join handling.
- Fixes #261
---
 .../config/AbstractStateMachineFactory.java   |  46 ++-
 .../statemachine/state/AbstractState.java     |  13 +
 .../state/CompositeStateListener.java         |  47 +++
 .../statemachine/state/JoinPseudoState.java   | 149 +++++--
 .../statemachine/state/RegionState.java       |  11 +-
 .../statemachine/state/State.java             |  13 +
 .../statemachine/state/StateListener.java     |  43 ++
 .../statemachine/state/StateMachineState.java |   2 +
 .../support/AbstractStateMachine.java         |  45 +-
 .../support/DefaultStateMachineExecutor.java  |  31 +-
 .../support/StateMachineUtils.java            |   8 +
 .../statemachine/state/JoinStateTests.java    | 191 ++++++++-
 .../recipes/tasks/TasksHandler.java           |   4 +-
 .../uml/UmlStateMachineModelFactoryTests.java |  51 +++
 .../statemachine/uml/multijoin-forkjoin.di    |   2 +
 .../uml/multijoin-forkjoin.notation           | 383 ++++++++++++++++++
 .../statemachine/uml/multijoin-forkjoin.uml   |  63 +++
 17 files changed, 1021 insertions(+), 81 deletions(-)
 create mode 100644 spring-statemachine-core/src/main/java/org/springframework/statemachine/state/CompositeStateListener.java
 create mode 100644 spring-statemachine-core/src/main/java/org/springframework/statemachine/state/StateListener.java
 create mode 100644 spring-statemachine-uml/src/test/resources/org/springframework/statemachine/uml/multijoin-forkjoin.di
 create mode 100644 spring-statemachine-uml/src/test/resources/org/springframework/statemachine/uml/multijoin-forkjoin.notation
 create mode 100644 spring-statemachine-uml/src/test/resources/org/springframework/statemachine/uml/multijoin-forkjoin.uml

diff --git a/spring-statemachine-core/src/main/java/org/springframework/statemachine/config/AbstractStateMachineFactory.java b/spring-statemachine-core/src/main/java/org/springframework/statemachine/config/AbstractStateMachineFactory.java
index f55f19c3..78b0c53f 100644
--- a/spring-statemachine-core/src/main/java/org/springframework/statemachine/config/AbstractStateMachineFactory.java
+++ b/spring-statemachine-core/src/main/java/org/springframework/statemachine/config/AbstractStateMachineFactory.java
@@ -61,6 +61,7 @@ import org.springframework.statemachine.state.ExitPseudoState;
 import org.springframework.statemachine.state.ForkPseudoState;
 import org.springframework.statemachine.state.HistoryPseudoState;
 import org.springframework.statemachine.state.JoinPseudoState;
+import org.springframework.statemachine.state.JoinPseudoState.JoinStateData;
 import org.springframework.statemachine.state.JunctionPseudoState;
 import org.springframework.statemachine.state.JunctionPseudoState.JunctionStateData;
 import org.springframework.statemachine.state.PseudoState;
@@ -631,34 +632,24 @@ public abstract class AbstractStateMachineFactory<S, E> extends LifecycleObjectS
 						joins.add(stateMap.get(fs));
 					}
 				}
-				S ss = null;
+
+				List<JoinStateData<S, E>> joinTargets = new ArrayList<JoinStateData<S, E>>();
 				Collection<TransitionData<S, E>> transitions = stateMachineTransitions.getTransitions();
 				for (TransitionData<S, E> tt : transitions) {
 					if (tt.getSource() == s) {
-						ss = tt.getTarget();
-						break;
+						StateHolder<S, E> holder = new StateHolder<S, E>(stateMap.get(tt.getTarget()));
+						if (holder.getState() == null) {
+							holderMap.put(tt.getTarget(), holder);
+						}
+						joinTargets.add(new JoinStateData<S, E>(holder, tt.getGuard()));
 					}
 				}
-				StateHolder<S, E> holder = new StateHolder<S, E>(stateMap.get(ss));
-				if (holder.getState() == null) {
-					holderMap.put(ss, holder);
-				}
-				JoinPseudoState<S, E> pseudoState = new JoinPseudoState<S, E>(joins, holder);
+				JoinPseudoState<S, E> pseudoState = new JoinPseudoState<S, E>(joins, joinTargets);
+
 				state = buildStateInternal(stateData.getState(), stateData.getDeferred(), stateData.getEntryActions(),
 						stateData.getExitActions(), pseudoState);
 				states.add(state);
 				stateMap.put(stateData.getState(), state);
-
-				// find joins sources and associate
-				for (Entry<S, State<S, E>> e : stateMap.entrySet()) {
-					State<S, E> value = e.getValue();
-					if (value.isOrthogonal()) {
-						Collection<State<S, E>> states2 = value.getStates();
-						if (states2.containsAll(joins)) {
-							((RegionState<S, E>)value).setJoin(pseudoState);
-						}
-					}
-				}
 			}
 		}
 
@@ -706,6 +697,23 @@ public abstract class AbstractStateMachineFactory<S, E> extends LifecycleObjectS
 			}
 		}
 
+		if (stateMachineTransitions.getJoins() != null) {
+			for (Entry<S, List<S>> entry : stateMachineTransitions.getJoins().entrySet()) {
+				if (stateMap.get(entry.getKey()) != null) {
+					List<S> entryList = entry.getValue();
+					for (S entryState : entryList) {
+						State<S, E> source = stateMap.get(entryState);
+						if (source != null && !source.isOrthogonal()) {
+							State<S, E> target = stateMap.get(entry.getKey());
+							DefaultExternalTransition<S, E> transition = new DefaultExternalTransition<S, E>(
+									source, target, null, null, null, null, null);
+							transitions.add(transition);
+						}
+					}
+				}
+			}
+		}
+
 		Transition<S, E> initialTransition = new InitialTransition<S, E>(initialState, initialAction);
 		StateMachine<S, E> machine = buildStateMachineInternal(states, transitions, initialState, initialTransition,
 				null, defaultExtendedState, historyState, contextEvents, beanFactory, taskExecutor, taskScheduler,
diff --git a/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/AbstractState.java b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/AbstractState.java
index 3c662449..a38ad5c6 100644
--- a/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/AbstractState.java
+++ b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/AbstractState.java
@@ -44,6 +44,7 @@ public abstract class AbstractState<S, E> implements State<S, E> {
 	private final Collection<Region<S, E>> regions = new ArrayList<Region<S, E>>();
 	private final StateMachine<S, E> submachine;
 	private List<Trigger<S, E>> triggers = new ArrayList<Trigger<S, E>>();
+	private final CompositeStateListener<S, E> stateListener = new CompositeStateListener<S, E>();
 
 	/**
 	 * Instantiates a new abstract state.
@@ -162,6 +163,7 @@ public abstract class AbstractState<S, E> implements State<S, E> {
 
 	@Override
 	public void exit(StateContext<S, E> context) {
+		stateListener.onExit(context);
 		for (Trigger<S, E> trigger : triggers) {
 			trigger.disarm();
 		}
@@ -169,6 +171,7 @@ public abstract class AbstractState<S, E> implements State<S, E> {
 
 	@Override
 	public void entry(StateContext<S, E> context) {
+		stateListener.onEntry(context);
 		for (Trigger<S, E> trigger : triggers) {
 			trigger.arm();
 		}
@@ -225,6 +228,16 @@ public abstract class AbstractState<S, E> implements State<S, E> {
 		return submachine != null;
 	}
 
+	@Override
+	public void addStateListener(StateListener<S, E> listener) {
+		stateListener.register(listener);
+	}
+
+	@Override
+	public void removeStateListener(StateListener<S, E> listener) {
+		stateListener.unregister(listener);
+	}
+
 	/**
 	 * Gets the submachine.
 	 *
diff --git a/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/CompositeStateListener.java b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/CompositeStateListener.java
new file mode 100644
index 00000000..4a739303
--- /dev/null
+++ b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/CompositeStateListener.java
@@ -0,0 +1,47 @@
+/*
+ * Copyright 2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.statemachine.state;
+
+import java.util.Iterator;
+
+import org.springframework.statemachine.StateContext;
+import org.springframework.statemachine.listener.AbstractCompositeListener;
+
+/**
+ * Composite state listener.
+ *
+ * @author Janne Valkealahti
+ *
+ * @param <S> the type of state
+ * @param <E> the type of event
+ */
+public class CompositeStateListener<S, E> extends AbstractCompositeListener<StateListener<S, E>>
+		implements StateListener<S, E> {
+
+	@Override
+	public void onEntry(StateContext<S, E> context) {
+		for (Iterator<StateListener<S, E>> iterator = getListeners().reverse(); iterator.hasNext();) {
+			iterator.next().onEntry(context);
+		}
+	}
+
+	@Override
+	public void onExit(StateContext<S, E> context) {
+		for (Iterator<StateListener<S, E>> iterator = getListeners().reverse(); iterator.hasNext();) {
+			iterator.next().onExit(context);
+		}
+	}
+}
diff --git a/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/JoinPseudoState.java b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/JoinPseudoState.java
index 929f6daf..8e130523 100644
--- a/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/JoinPseudoState.java
+++ b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/JoinPseudoState.java
@@ -18,9 +18,12 @@ package org.springframework.statemachine.state;
 import java.util.ArrayList;
 import java.util.List;
 
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 import org.springframework.statemachine.StateContext;
-import org.springframework.statemachine.listener.StateMachineListenerAdapter;
+import org.springframework.statemachine.guard.Guard;
 import org.springframework.statemachine.state.PseudoStateContext.PseudoAction;
+import org.springframework.statemachine.support.StateMachineUtils;
 import org.springframework.util.Assert;
 
 /**
@@ -33,36 +36,42 @@ import org.springframework.util.Assert;
  */
 public class JoinPseudoState<S, E> extends AbstractPseudoState<S, E> {
 
+	private final static Log log = LogFactory.getLog(JoinPseudoState.class);
 	private final List<State<S, E>> joins;
-	private volatile JoinTracker tracker;
-	private final StateHolder<S, E> state;
+	private final JoinTracker tracker;
+	private final List<JoinStateData<S, E>> joinTargets;
 
 	/**
 	 * Instantiates a new join pseudo state.
 	 *
 	 * @param joins the joins
-	 * @param state the holder for target state
+	 * @param joinTargets the target states
 	 */
-	public JoinPseudoState(List<State<S, E>> joins, StateHolder<S, E> state) {
+	public JoinPseudoState(List<State<S, E>> joins, List<JoinStateData<S, E>> joinTargets) {
 		super(PseudoStateKind.JOIN);
-		Assert.notNull(state, "Holder must be set");
 		this.joins = joins;
-		this.state = state;
+		this.joinTargets = joinTargets;
+		this.tracker = new JoinTracker();
 	}
 
 	@Override
 	public State<S, E> entry(StateContext<S, E> context) {
-		tracker = new JoinTracker(this, new ArrayList<State<S,E>>(joins));
-		context.getStateMachine().addStateListener(tracker);
-		return state.getState();
+		if (!tracker.isNotified()) {
+			return null;
+		}
+		State<S, E> s = null;
+		for (JoinStateData<S, E> c : joinTargets) {
+			s = c.getState();
+			if (c.guard != null && evaluateInternal(c.guard, context)) {
+				break;
+			}
+		}
+		return s;
 	}
 
 	@Override
 	public void exit(StateContext<S, E> context) {
-		if (context != null) {
-			context.getStateMachine().removeStateListener(tracker);
-		}
-		tracker = null;
+		tracker.reset();
 	}
 
 	/**
@@ -74,28 +83,112 @@ public class JoinPseudoState<S, E> extends AbstractPseudoState<S, E> {
 		return joins;
 	}
 
-	private class JoinTracker extends StateMachineListenerAdapter<S, E> {
+	private boolean evaluateInternal(Guard<S, E> guard, StateContext<S, E> context) {
+		try {
+			return guard.evaluate(context);
+		} catch (Throwable t) {
+			log.warn("Deny guard due to throw as GUARD should not error", t);
+			return false;
+		}
+	}
+
+	private class JoinTracker {
 
-		private final PseudoState<S, E> pseudoState;
 		private final List<State<S, E>> track;
 		private volatile boolean notified = false;
 
-		public JoinTracker(PseudoState<S, E> pseudoState, List<State<S, E>> track) {
-			this.pseudoState = pseudoState;
-			this.track = track;
-		}
+		public JoinTracker() {
+			this.track = new ArrayList<State<S,E>>(joins);
+			for (State<S, E> tt : joins) {
+				final State<S, E> t = tt;
+				t.addStateListener(new StateListener<S, E>() {
 
-		@Override
-		public synchronized void stateChanged(State<S, E> from, State<S, E> to) {
-			if (!notified && track.size() > 0) {
-				track.remove(to);
-				if (track.size() == 0) {
-					notified = true;
-					notifyContext(new DefaultPseudoStateContext<S, E>(pseudoState, PseudoAction.JOIN_COMPLETED));
-				}
+					@Override
+					public void onEntry(StateContext<S, E> context) {
+						if (StateMachineUtils.isPseudoState(context.getTransition().getTarget(), PseudoStateKind.END)) {
+							if (!notified && track.size() > 0) {
+								track.remove(t);
+								if (track.size() == 0) {
+									notified = true;
+									notifyContext(new DefaultPseudoStateContext<S, E>(JoinPseudoState.this, PseudoAction.JOIN_COMPLETED));
+								}
+							}
+						}
+					}
+
+					@Override
+					public void onExit(StateContext<S, E> context) {
+						if (!notified && track.size() > 0) {
+							track.remove(t);
+							if (track.size() == 0) {
+								notified = true;
+								notifyContext(new DefaultPseudoStateContext<S, E>(JoinPseudoState.this, PseudoAction.JOIN_COMPLETED));
+							}
+						}
+					}
+				});
 			}
 		}
 
+		void reset() {
+			track.clear();
+			track.addAll(joins);
+			notified = false;
+		}
+
+		public boolean isNotified() {
+			return notified;
+		}
 	}
 
+	/**
+	 * Data class wrapping join {@link State} and {@link Guard}
+	 * together.
+	 *
+	 * @param <S> the type of state
+	 * @param <E> the type of event
+	 */
+	public static class JoinStateData<S, E> {
+		private final StateHolder<S, E> state;
+		private final Guard<S, E> guard;
+
+		/**
+		 * Instantiates a new join state data.
+		 *
+		 * @param state the state holder
+		 * @param guard the guard
+		 */
+		public JoinStateData(StateHolder<S, E> state, Guard<S, E> guard) {
+			Assert.notNull(state, "Holder must be set");
+			this.state = state;
+			this.guard = guard;
+		}
+
+		/**
+		 * Gets the state holder.
+		 *
+		 * @return the state holder
+		 */
+		public StateHolder<S, E> getStateHolder() {
+			return state;
+		}
+
+		/**
+		 * Gets the state.
+		 *
+		 * @return the state
+		 */
+		public State<S, E> getState() {
+			return state.getState();
+		}
+
+		/**
+		 * Gets the guard.
+		 *
+		 * @return the guard
+		 */
+		public Guard<S, E> getGuard() {
+			return guard;
+		}
+	}
 }
diff --git a/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/RegionState.java b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/RegionState.java
index cc54b650..1c07afec 100644
--- a/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/RegionState.java
+++ b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/RegionState.java
@@ -34,8 +34,6 @@ import org.springframework.statemachine.support.StateMachineUtils;
  */
 public class RegionState<S, E> extends AbstractState<S, E> {
 
-	private JoinPseudoState<S, E> join;
-
 	/**
 	 * Instantiates a new region state.
 	 *
@@ -129,6 +127,7 @@ public class RegionState<S, E> extends AbstractState<S, E> {
 
 	@Override
 	public void exit(StateContext<S, E> context) {
+		super.exit(context);
 		for (Region<S, E> region : getRegions()) {
 			if (region.getState() != null) {
 				region.getState().exit(context);
@@ -145,9 +144,7 @@ public class RegionState<S, E> extends AbstractState<S, E> {
 
 	@Override
 	public void entry(StateContext<S, E> context) {
-		if (join != null) {
-			join.entry(context);
-		}
+		super.entry(context);
 		Collection<? extends Action<S, E>> actions = getEntryActions();
 		if (actions != null) {
 			for (Action<S, E> action : actions) {
@@ -201,10 +198,6 @@ public class RegionState<S, E> extends AbstractState<S, E> {
 		return states;
 	}
 
-	public void setJoin(JoinPseudoState<S, E> join) {
-		this.join = join;
-	}
-
 	@Override
 	public String toString() {
 		return "RegionState [getIds()=" + getIds() + ", getClass()=" + getClass() + ", hashCode()=" + hashCode()
diff --git a/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/State.java b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/State.java
index ec0babc1..339941f7 100644
--- a/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/State.java
+++ b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/State.java
@@ -147,4 +147,17 @@ public interface State<S, E> {
 	 */
 	boolean isSubmachineState();
 
+	/**
+	 * Adds the state listener.
+	 *
+	 * @param listener the listener
+	 */
+	void addStateListener(StateListener<S, E> listener);
+
+	/**
+	 * Removes the state listener.
+	 *
+	 * @param listener the listener
+	 */
+	void removeStateListener(StateListener<S, E> listener);
 }
diff --git a/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/StateListener.java b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/StateListener.java
new file mode 100644
index 00000000..48c6c166
--- /dev/null
+++ b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/StateListener.java
@@ -0,0 +1,43 @@
+/*
+ * Copyright 2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.statemachine.state;
+
+import org.springframework.statemachine.StateContext;
+
+/**
+ * {@code StateListener} for various state events.
+ *
+ * @author Janne Valkealahti
+ *
+ * @param <S> the type of state
+ * @param <E> the type of event
+ */
+public interface StateListener<S, E> {
+
+	/**
+	 * Called when {@link State} want to notify of its entry.
+	 *
+	 * @param context the state context
+	 */
+	void onEntry(StateContext<S, E> context);
+
+	/**
+	 * Called when {@link State} want to notify of its exit.
+	 *
+	 * @param context the state context
+	 */
+	void onExit(StateContext<S, E> context);
+}
diff --git a/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/StateMachineState.java b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/StateMachineState.java
index a60a7b53..957fb0b4 100644
--- a/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/StateMachineState.java
+++ b/spring-statemachine-core/src/main/java/org/springframework/statemachine/state/StateMachineState.java
@@ -136,6 +136,7 @@ public class StateMachineState<S, E> extends AbstractState<S, E> {
 
 	@Override
 	public void exit(StateContext<S, E> context) {
+		super.exit(context);
 		// don't stop if it looks like we're coming back
 		// stop would cause start with entry which would
 		// enable default transition and state
@@ -156,6 +157,7 @@ public class StateMachineState<S, E> extends AbstractState<S, E> {
 
 	@Override
 	public void entry(final StateContext<S, E> context) {
+		super.entry(context);
 		Collection<? extends Action<S, E>> actions = getEntryActions();
 		if (actions != null && !isLocal(context)) {
 			for (Action<S, E> action : actions) {
diff --git a/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/AbstractStateMachine.java b/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/AbstractStateMachine.java
index 93bd3990..3333a35c 100644
--- a/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/AbstractStateMachine.java
+++ b/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/AbstractStateMachine.java
@@ -45,7 +45,6 @@ import org.springframework.statemachine.region.Region;
 import org.springframework.statemachine.state.AbstractState;
 import org.springframework.statemachine.state.ForkPseudoState;
 import org.springframework.statemachine.state.HistoryPseudoState;
-import org.springframework.statemachine.state.JoinPseudoState;
 import org.springframework.statemachine.state.PseudoState;
 import org.springframework.statemachine.state.PseudoStateContext;
 import org.springframework.statemachine.state.PseudoStateKind;
@@ -286,11 +285,15 @@ public abstract class AbstractStateMachine<S, E> extends StateMachineObjectSuppo
 				// TODO: fix above stateContext as it's not used
 				notifyTransitionStart(buildStateContext(Stage.TRANSITION_START, message, t, getRelayStateMachine()));
 				notifyTransition(buildStateContext(Stage.TRANSITION, message, t, getRelayStateMachine()));
-				if (t.getKind() == TransitionKind.INITIAL) {
-					switchToState(t.getTarget(), message, t, getRelayStateMachine());
-					notifyStateMachineStarted(buildStateContext(Stage.STATEMACHINE_START, message, t, getRelayStateMachine()));
-				} else if (t.getKind() != TransitionKind.INTERNAL) {
-					switchToState(t.getTarget(), message, t, getRelayStateMachine());
+				if (t.getTarget().getPseudoState() != null && t.getTarget().getPseudoState().getKind() == PseudoStateKind.JOIN) {
+					exitFromState(t.getSource(), message, t, getRelayStateMachine());
+				} else {
+					if (t.getKind() == TransitionKind.INITIAL) {
+						switchToState(t.getTarget(), message, t, getRelayStateMachine());
+						notifyStateMachineStarted(buildStateContext(Stage.STATEMACHINE_START, message, t, getRelayStateMachine()));
+					} else if (t.getKind() != TransitionKind.INTERNAL) {
+						switchToState(t.getTarget(), message, t, getRelayStateMachine());
+					}
 				}
 				// TODO: looks like events should be called here and anno processing earlier
 				notifyTransitionEnd(buildStateContext(Stage.TRANSITION_END, message, t, getRelayStateMachine()));
@@ -784,25 +787,29 @@ public abstract class AbstractStateMachine<S, E> extends StateMachineObjectSuppo
 					@Override
 					public void onContext(PseudoStateContext<S, E> context) {
 						PseudoState<S, E> pseudoState = context.getPseudoState();
-						if (pseudoState.getKind() == PseudoStateKind.JOIN) {
-							List<State<S, E>> joins = ((JoinPseudoState<S, E>)context.getPseudoState()).getJoins();
-							for (State<S, E> join : joins) {
-								exitFromState(join, null, null, getRelayStateMachine());
-							}
-						}
-						State<S, E> toState = findStateWithPseudoState(pseudoState);
+						State<S, E> toStateOrig = findStateWithPseudoState(pseudoState);
 						StateContext<S, E> stateContext = buildStateContext(Stage.STATE_EXIT, null, null, getRelayStateMachine());
+						State<S, E> toState = followLinkedPseudoStates(toStateOrig, stateContext);
+						// TODO: try to find matching transition based on direct link.
+						// should make this built-in in pseudostates
+						Transition<S, E> transition = findTransition(toStateOrig, toState);
+						switchToState(toState, null, transition, getRelayStateMachine());
 						pseudoState.exit(stateContext);
-						toState = followLinkedPseudoStates(toState, stateContext);
-						// should figure out what transition to use as we pass null for now
-						// which is then expected in exitCurrentState
-						switchToState(toState, null, null, getRelayStateMachine());
 					}
 				});
 			}
 		}
 	}
 
+	private Transition<S, E> findTransition(State<S, E> from, State<S, E> to) {
+		for (Transition<S, E> transition : transitions) {
+			if (transition.getSource() == from && transition.getTarget() == to) {
+				return transition;
+			}
+		}
+		return null;
+	}
+
 	private State<S, E> findStateWithPseudoState(PseudoState<S, E> pseudoState) {
 		for (State<S, E> s : states) {
 			if (s.getPseudoState() == pseudoState) {
@@ -984,9 +991,7 @@ public abstract class AbstractStateMachine<S, E> extends StateMachineObjectSuppo
 					exitFromState(r.getState(), message, transition, stateMachine, sources, targets);
 				}
 			}
-			if (transition == null) {
-				exitFromState(currentState, message, transition, stateMachine, sources, targets);
-			}
+			exitFromState(currentState, message, transition, stateMachine, sources, targets);
 		} else {
 			exitFromState(currentState, message, transition, stateMachine, sources, targets);
 		}
diff --git a/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/DefaultStateMachineExecutor.java b/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/DefaultStateMachineExecutor.java
index fad850c5..bbb2277b 100644
--- a/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/DefaultStateMachineExecutor.java
+++ b/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/DefaultStateMachineExecutor.java
@@ -19,12 +19,14 @@ import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Collections;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.LinkedList;
 import java.util.List;
 import java.util.ListIterator;
 import java.util.Map;
 import java.util.Map.Entry;
 import java.util.Queue;
+import java.util.Set;
 import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicReference;
@@ -36,9 +38,11 @@ import org.springframework.core.task.TaskExecutor;
 import org.springframework.messaging.Message;
 import org.springframework.messaging.MessageHeaders;
 import org.springframework.statemachine.StateContext;
+import org.springframework.statemachine.StateContext.Stage;
 import org.springframework.statemachine.StateMachine;
 import org.springframework.statemachine.StateMachineSystemConstants;
-import org.springframework.statemachine.StateContext.Stage;
+import org.springframework.statemachine.state.JoinPseudoState;
+import org.springframework.statemachine.state.PseudoStateKind;
 import org.springframework.statemachine.state.State;
 import org.springframework.statemachine.transition.Transition;
 import org.springframework.statemachine.trigger.DefaultTriggerContext;
@@ -172,6 +176,9 @@ public class DefaultStateMachineExecutor<S, E> extends LifecycleObjectSupport im
 		interceptors.add(interceptor);
 	}
 
+	private final Set<Transition<S, E>> joinSyncTransitions = new HashSet<>();
+	private final Set<State<S, E>> joinSyncStates = new HashSet<>();
+
 	private boolean handleTriggerTrans(List<Transition<S, E>> trans, Message<E> queuedMessage) {
 		boolean transit = false;
 		for (Transition<S, E> t : trans) {
@@ -190,6 +197,28 @@ public class DefaultStateMachineExecutor<S, E> extends LifecycleObjectSupport im
 				continue;
 			}
 
+			// special handling of join
+			if (StateMachineUtils.isPseudoState(t.getTarget(), PseudoStateKind.JOIN)) {
+				if (joinSyncStates.isEmpty()) {
+					List<State<S, E>> joins = ((JoinPseudoState<S, E>)t.getTarget().getPseudoState()).getJoins();
+					joinSyncStates.addAll(joins);
+				}
+				joinSyncTransitions.add(t);
+				boolean removed = joinSyncStates.remove(t.getSource());
+				boolean joincomplete = removed & joinSyncStates.isEmpty();
+				if (joincomplete) {
+					for (Transition<S, E> tt : joinSyncTransitions) {
+						StateContext<S, E> stateContext = buildStateContext(queuedMessage, tt, relayStateMachine);
+						tt.transit(stateContext);
+						stateMachineExecutorTransit.transit(tt, stateContext, queuedMessage);
+					}
+					joinSyncTransitions.clear();
+					break;
+				} else {
+					continue;
+				}
+			}
+
 			StateContext<S, E> stateContext = buildStateContext(queuedMessage, t, relayStateMachine);
 			try {
 				stateContext = interceptors.preTransition(stateContext);
diff --git a/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/StateMachineUtils.java b/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/StateMachineUtils.java
index 4ccf680b..3e669d0e 100644
--- a/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/StateMachineUtils.java
+++ b/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/StateMachineUtils.java
@@ -95,6 +95,14 @@ public abstract class StateMachineUtils {
 		}
 	}
 
+	public static <S, E> boolean isPseudoState(State<S, E> state, PseudoStateKind kind) {
+		if (state != null) {
+			PseudoState<S, E> pseudoState = state.getPseudoState();
+			return pseudoState != null && pseudoState.getKind() == kind;
+		}
+		return false;
+	}
+
 	public static <S> Collection<String> toStringCollection(Collection<S> collection) {
 		Collection<String> c = new ArrayList<String>();
 		for (S item : collection) {
diff --git a/spring-statemachine-core/src/test/java/org/springframework/statemachine/state/JoinStateTests.java b/spring-statemachine-core/src/test/java/org/springframework/statemachine/state/JoinStateTests.java
index 5e787513..d63de650 100644
--- a/spring-statemachine-core/src/test/java/org/springframework/statemachine/state/JoinStateTests.java
+++ b/spring-statemachine-core/src/test/java/org/springframework/statemachine/state/JoinStateTests.java
@@ -16,6 +16,7 @@
 package org.springframework.statemachine.state;
 
 import static org.hamcrest.Matchers.contains;
+import static org.hamcrest.Matchers.containsInAnyOrder;
 import static org.hamcrest.Matchers.is;
 import static org.hamcrest.Matchers.notNullValue;
 import static org.junit.Assert.assertThat;
@@ -24,18 +25,22 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicBoolean;
 
 import org.junit.Test;
 import org.springframework.context.annotation.AnnotationConfigApplicationContext;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.messaging.Message;
 import org.springframework.statemachine.AbstractStateMachineTests;
 import org.springframework.statemachine.ObjectStateMachine;
+import org.springframework.statemachine.StateMachine;
 import org.springframework.statemachine.StateMachineSystemConstants;
 import org.springframework.statemachine.config.EnableStateMachine;
 import org.springframework.statemachine.config.EnumStateMachineConfigurerAdapter;
 import org.springframework.statemachine.config.builders.StateMachineStateConfigurer;
 import org.springframework.statemachine.config.builders.StateMachineTransitionConfigurer;
 import org.springframework.statemachine.listener.StateMachineListenerAdapter;
+import org.springframework.statemachine.support.StateMachineInterceptorAdapter;
 import org.springframework.statemachine.transition.Transition;
 
 public class JoinStateTests extends AbstractStateMachineTests {
@@ -105,16 +110,17 @@ public class JoinStateTests extends AbstractStateMachineTests {
 		machine.sendEvent(TestEvents.E1);
 		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
 		assertThat(listener.stateChangedCount, is(3));
+		assertThat(machine.getState().getIds(), containsInAnyOrder(TestStates.S2, TestStates.S20, TestStates.S30));
 
 		listener.reset(1);
 		machine.sendEvent(TestEvents.E2);
 		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
 		assertThat(listener.stateChangedCount, is(1));
 
-		listener.reset(3);
+		listener.reset(2);
 		machine.sendEvent(TestEvents.E3);
 		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
-		assertThat(listener.stateChangedCount, is(3));
+		assertThat(listener.stateChangedCount, is(2));
 
 		assertThat(machine.getState().getIds(), contains(TestStates.S4));
 	}
@@ -185,14 +191,128 @@ public class JoinStateTests extends AbstractStateMachineTests {
 		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
 		assertThat(listener.stateChangedCount, is(1));
 
-		listener.reset(3);
+		listener.reset(2);
 		machine.sendEvent(TestEvents.E3);
 		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
+		assertThat(listener.stateChangedCount, is(2));
+
+		assertThat(machine.getState().getIds(), contains(TestStates.S4));
+	}
+
+	@Test
+	@SuppressWarnings("unchecked")
+	public void testMultiJoin1() throws Exception {
+		context.register(BaseConfig.class, Config3.class);
+		context.refresh();
+		ObjectStateMachine<TestStates,TestEvents> machine =
+				context.getBean(StateMachineSystemConstants.DEFAULT_ID_STATEMACHINE, ObjectStateMachine.class);
+		TestListener listener = new TestListener();
+		machine.addStateListener(listener);
+		listener.reset(1);
+		assertThat(machine, notNullValue());
+		machine.start();
+		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
+		assertThat(listener.stateChangedCount, is(1));
+
+		listener.reset(3);
+		machine.sendEvent(TestEvents.E1);
+		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
 		assertThat(listener.stateChangedCount, is(3));
 
+		listener.reset(1);
+		machine.sendEvent(TestEvents.E2);
+		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
+		assertThat(listener.stateChangedCount, is(1));
+
+		listener.reset(2);
+		machine.sendEvent(TestEvents.E3);
+		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
+		assertThat(listener.stateChangedCount, is(2));
+
 		assertThat(machine.getState().getIds(), contains(TestStates.S4));
 	}
 
+	@Test
+	@SuppressWarnings("unchecked")
+	public void testMultiJoin2() throws Exception {
+		context.register(BaseConfig.class, Config3.class);
+		context.refresh();
+		ObjectStateMachine<TestStates,TestEvents> machine =
+				context.getBean(StateMachineSystemConstants.DEFAULT_ID_STATEMACHINE, ObjectStateMachine.class);
+		TestListener listener = new TestListener();
+		machine.addStateListener(listener);
+		listener.reset(1);
+		assertThat(machine, notNullValue());
+		machine.start();
+		machine.getExtendedState().getVariables().put("foo", "bar");
+		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
+		assertThat(listener.stateChangedCount, is(1));
+
+		listener.reset(3);
+		machine.sendEvent(TestEvents.E1);
+		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
+		assertThat(listener.stateChangedCount, is(3));
+
+		listener.reset(1);
+		machine.sendEvent(TestEvents.E2);
+		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
+		assertThat(listener.stateChangedCount, is(1));
+
+		listener.reset(2);
+		machine.sendEvent(TestEvents.E3);
+		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
+		assertThat(listener.stateChangedCount, is(2));
+
+		assertThat(machine.getState().getIds(), contains(TestStates.SF));
+	}
+
+	@Test
+	@SuppressWarnings("unchecked")
+	public void testInterceptorPostStateChangeTransitionNotNull() throws Exception {
+		context.register(BaseConfig.class, Config1.class);
+		context.refresh();
+		ObjectStateMachine<TestStates,TestEvents> machine =
+				context.getBean(StateMachineSystemConstants.DEFAULT_ID_STATEMACHINE, ObjectStateMachine.class);
+		TestListener listener = new TestListener();
+		machine.addStateListener(listener);
+
+		final AtomicBoolean nullCheck = new AtomicBoolean(false);
+		machine.addStateMachineInterceptor(new StateMachineInterceptorAdapter<TestStates,TestEvents>() {
+			@Override
+			public void postStateChange(State<TestStates, TestEvents> state, Message<TestEvents> message,
+					Transition<TestStates, TestEvents> transition, StateMachine<TestStates, TestEvents> stateMachine) {
+				if (state.getId() == TestStates.S4) {
+					nullCheck.set(transition == null);
+				}
+				super.postStateChange(state, message, transition, stateMachine);
+			}
+		});
+
+		listener.reset(1);
+		assertThat(machine, notNullValue());
+		machine.start();
+		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
+		assertThat(listener.stateChangedCount, is(1));
+
+		listener.reset(3);
+		machine.sendEvent(TestEvents.E1);
+		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
+		assertThat(listener.stateChangedCount, is(3));
+
+		listener.reset(1);
+		machine.sendEvent(TestEvents.E2);
+		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
+		assertThat(listener.stateChangedCount, is(1));
+
+		listener.reset(2);
+		machine.sendEvent(TestEvents.E3);
+		assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
+		assertThat(listener.stateChangedCount, is(2));
+
+		assertThat(machine.getState().getIds(), contains(TestStates.S4));
+		assertThat("Interceptor postStateChange has null transition", nullCheck.get(), is(false));
+	}
+
 	@Configuration
 	@EnableStateMachine
 	static class Config1 extends EnumStateMachineConfigurerAdapter<TestStates, TestEvents> {
@@ -312,6 +432,71 @@ public class JoinStateTests extends AbstractStateMachineTests {
 
 	}
 
+	@Configuration
+	@EnableStateMachine
+	static class Config3 extends EnumStateMachineConfigurerAdapter<TestStates, TestEvents> {
+
+		@Override
+		public void configure(StateMachineStateConfigurer<TestStates, TestEvents> states) throws Exception {
+			states
+				.withStates()
+					.initial(TestStates.SI)
+					.state(TestStates.S2)
+					.join(TestStates.S3)
+					.state(TestStates.SF)
+					.state(TestStates.S4)
+					.and()
+					.withStates()
+						.parent(TestStates.S2)
+						.initial(TestStates.S20)
+						.end(TestStates.S21)
+						.and()
+					.withStates()
+						.parent(TestStates.S2)
+						.initial(TestStates.S30)
+						.end(TestStates.S31);
+		}
+
+		@Override
+		public void configure(StateMachineTransitionConfigurer<TestStates, TestEvents> transitions) throws Exception {
+			transitions
+				.withExternal()
+					.source(TestStates.SI)
+					.target(TestStates.S2)
+					.event(TestEvents.E1)
+					.and()
+				.withExternal()
+					.source(TestStates.S20)
+					.target(TestStates.S21)
+					.event(TestEvents.E2)
+					.and()
+				.withExternal()
+					.source(TestStates.S30)
+					.target(TestStates.S31)
+					.event(TestEvents.E3)
+					.and()
+				.withJoin()
+					.source(TestStates.S2)
+					.target(TestStates.S3)
+					.and()
+				.withExternal()
+					.source(TestStates.S3)
+					.target(TestStates.SF)
+					.guardExpression("!extendedState.variables.isEmpty()")
+					.and()
+				.withExternal()
+					.source(TestStates.S3)
+					.target(TestStates.S4)
+					.guardExpression("extendedState.variables.isEmpty()")
+					.and()
+				.withExternal()
+					.source(TestStates.S4)
+					.target(TestStates.SI)
+					.event(TestEvents.E4);
+		}
+
+	}
+
 	private static class TestListener extends StateMachineListenerAdapter<TestStates, TestEvents> {
 
 		volatile CountDownLatch stateChangedLatch = new CountDownLatch(1);
diff --git a/spring-statemachine-recipes/src/main/java/org/springframework/statemachine/recipes/tasks/TasksHandler.java b/spring-statemachine-recipes/src/main/java/org/springframework/statemachine/recipes/tasks/TasksHandler.java
index b8d0c989..bcf60f7c 100644
--- a/spring-statemachine-recipes/src/main/java/org/springframework/statemachine/recipes/tasks/TasksHandler.java
+++ b/spring-statemachine-recipes/src/main/java/org/springframework/statemachine/recipes/tasks/TasksHandler.java
@@ -272,7 +272,9 @@ public class TasksHandler {
 					.initial(initial)
 					.state(task, runnableAction(node.getData().runnable, node.getData().id.toString()), null);
 
-			joinStates.add(task);
+			if (node.getChildren().isEmpty()) {
+				joinStates.add(task);
+			}
 
 			stateMachineTransitionConfigurer
 				.withExternal()
diff --git a/spring-statemachine-uml/src/test/java/org/springframework/statemachine/uml/UmlStateMachineModelFactoryTests.java b/spring-statemachine-uml/src/test/java/org/springframework/statemachine/uml/UmlStateMachineModelFactoryTests.java
index 12d48132..12464673 100644
--- a/spring-statemachine-uml/src/test/java/org/springframework/statemachine/uml/UmlStateMachineModelFactoryTests.java
+++ b/spring-statemachine-uml/src/test/java/org/springframework/statemachine/uml/UmlStateMachineModelFactoryTests.java
@@ -339,6 +339,39 @@ public class UmlStateMachineModelFactoryTests extends AbstractUmlTests {
 		assertThat(stateMachine.getState().getIds(), containsInAnyOrder("SF"));
 	}
 
+	@Test
+	@SuppressWarnings("unchecked")
+	public void testMultiJoinForkJoin1() {
+		context.register(Config20.class);
+		context.refresh();
+		StateMachine<String, String> stateMachine = context.getBean(StateMachine.class);
+		stateMachine.start();
+		assertThat(stateMachine.getState().getIds(), containsInAnyOrder("SI"));
+		stateMachine.sendEvent("E1");
+		assertThat(stateMachine.getState().getIds(), containsInAnyOrder("S2", "S20", "S30"));
+		stateMachine.sendEvent("E2");
+		assertThat(stateMachine.getState().getIds(), containsInAnyOrder("S2", "S21", "S30"));
+		stateMachine.sendEvent("E3");
+		assertThat(stateMachine.getState().getIds(), containsInAnyOrder("S4"));
+	}
+
+	@Test
+	@SuppressWarnings("unchecked")
+	public void testMultiJoinForkJoin2() {
+		context.register(Config20.class);
+		context.refresh();
+		StateMachine<String, String> stateMachine = context.getBean(StateMachine.class);
+		stateMachine.start();
+		stateMachine.getExtendedState().getVariables().put("foo", "bar");
+		assertThat(stateMachine.getState().getIds(), containsInAnyOrder("SI"));
+		stateMachine.sendEvent("E1");
+		assertThat(stateMachine.getState().getIds(), containsInAnyOrder("S2", "S20", "S30"));
+		stateMachine.sendEvent("E2");
+		assertThat(stateMachine.getState().getIds(), containsInAnyOrder("S2", "S21", "S30"));
+		stateMachine.sendEvent("E3");
+		assertThat(stateMachine.getState().getIds(), containsInAnyOrder("SF"));
+	}
+
 	@Test
 	@SuppressWarnings("unchecked")
 	public void testSimpleHistoryShallow() {
@@ -984,6 +1017,24 @@ public class UmlStateMachineModelFactoryTests extends AbstractUmlTests {
 		}
 	}
 
+	@Configuration
+	@EnableStateMachine
+	public static class Config20 extends StateMachineConfigurerAdapter<String, String> {
+
+		@Override
+		public void configure(StateMachineModelConfigurer<String, String> model) throws Exception {
+			model
+				.withModel()
+					.factory(modelFactory());
+		}
+
+		@Bean
+		public StateMachineModelFactory<String, String> modelFactory() {
+			Resource model = new ClassPathResource("org/springframework/statemachine/uml/multijoin-forkjoin.uml");
+			return new UmlStateMachineModelFactory(model);
+		}
+	}
+
 	public static class LatchAction implements Action<String, String> {
 		CountDownLatch latch = new CountDownLatch(1);
 		@Override
diff --git a/spring-statemachine-uml/src/test/resources/org/springframework/statemachine/uml/multijoin-forkjoin.di b/spring-statemachine-uml/src/test/resources/org/springframework/statemachine/uml/multijoin-forkjoin.di
new file mode 100644
index 00000000..bf9abab3
--- /dev/null
+++ b/spring-statemachine-uml/src/test/resources/org/springframework/statemachine/uml/multijoin-forkjoin.di
@@ -0,0 +1,2 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<xmi:XMI xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI"/>
diff --git a/spring-statemachine-uml/src/test/resources/org/springframework/statemachine/uml/multijoin-forkjoin.notation b/spring-statemachine-uml/src/test/resources/org/springframework/statemachine/uml/multijoin-forkjoin.notation
new file mode 100644
index 00000000..cc223e30
--- /dev/null
+++ b/spring-statemachine-uml/src/test/resources/org/springframework/statemachine/uml/multijoin-forkjoin.notation
@@ -0,0 +1,383 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<notation:Diagram xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI" xmlns:ecore="http://www.eclipse.org/emf/2002/Ecore" xmlns:notation="http://www.eclipse.org/gmf/runtime/1.0.2/notation" xmlns:style="http://www.eclipse.org/papyrus/infra/viewpoints/policy/style" xmlns:uml="http://www.eclipse.org/uml2/5.0.0/UML" xmi:id="_CsJ_AAPIEeaXyaQL1WyV3A" type="PapyrusUMLStateMachineDiagram" name="StateMachine Diagram" measurementUnit="Pixel">
+  <children xmi:type="notation:Shape" xmi:id="_CsJ_AQPIEeaXyaQL1WyV3A" type="StateMachine_Shape">
+    <children xmi:type="notation:DecorationNode" xmi:id="_CsJ_AgPIEeaXyaQL1WyV3A" type="StateMachine_NameLabel">
+      <layoutConstraint xmi:type="notation:Bounds" xmi:id="_CsJ_AwPIEeaXyaQL1WyV3A" width="834" height="20"/>
+    </children>
+    <children xmi:type="notation:BasicCompartment" xmi:id="_44HGYFhbEea5u-C4k4QikQ" type="StateMachine_RegionCompartment">
+      <children xmi:type="notation:Shape" xmi:id="_CsJ_BQPIEeaXyaQL1WyV3A" type="Region_Shape">
+        <eAnnotations xmi:type="ecore:EAnnotation" xmi:id="_CsJ_BgPIEeaXyaQL1WyV3A" source="RegionAnnotationKey">
+          <details xmi:type="ecore:EStringToStringMapEntry" xmi:id="_CsJ_BwPIEeaXyaQL1WyV3A" key="RegionZoneKey" value=""/>
+        </eAnnotations>
+        <children xmi:type="notation:BasicCompartment" xmi:id="_44IUgFhbEea5u-C4k4QikQ" type="Region_SubvertexCompartment">
+          <children xmi:type="notation:Shape" xmi:id="_IPcocAPIEeaXyaQL1WyV3A" type="Pseudostate_InitialShape">
+            <children xmi:type="notation:DecorationNode" xmi:id="_IPdPgAPIEeaXyaQL1WyV3A" type="Pseudostate_InitialFloatingNameLabel">
+              <layoutConstraint xmi:type="notation:Location" xmi:id="_IPdPgQPIEeaXyaQL1WyV3A" x="25" y="3"/>
+            </children>
+            <children xmi:type="notation:DecorationNode" xmi:id="_IPdPggPIEeaXyaQL1WyV3A" type="Pseudostate_InitialStereotypeLabel">
+              <layoutConstraint xmi:type="notation:Location" xmi:id="_IPdPgwPIEeaXyaQL1WyV3A" x="25" y="-10"/>
+            </children>
+            <element xmi:type="uml:Pseudostate" href="multijoin-forkjoin.uml#_IPSQYAPIEeaXyaQL1WyV3A"/>
+            <layoutConstraint xmi:type="notation:Bounds" xmi:id="_IPcocQPIEeaXyaQL1WyV3A" x="13" y="85"/>
+          </children>
+          <children xmi:type="notation:Shape" xmi:id="_Iy1pYAPIEeaXyaQL1WyV3A" type="State_Shape">
+            <children xmi:type="notation:DecorationNode" xmi:id="_Iy2QcAPIEeaXyaQL1WyV3A" type="State_NameLabel"/>
+            <children xmi:type="notation:DecorationNode" xmi:id="_Iy2QcQPIEeaXyaQL1WyV3A" type="State_FloatingNameLabel">
+              <layoutConstraint xmi:type="notation:Location" xmi:id="_Iy2QcgPIEeaXyaQL1WyV3A" x="40"/>
+            </children>
+            <children xmi:type="notation:BasicCompartment" xmi:id="_44I7kFhbEea5u-C4k4QikQ" type="State_RegionCompartment">
+              <layoutConstraint xmi:type="notation:Bounds" xmi:id="_Iy2QdAPIEeaXyaQL1WyV3A"/>
+            </children>
+            <element xmi:type="uml:State" href="multijoin-forkjoin.uml#_IyviwAPIEeaXyaQL1WyV3A"/>
+            <layoutConstraint xmi:type="notation:Bounds" xmi:id="_Iy1pYQPIEeaXyaQL1WyV3A" x="70" y="87"/>
+          </children>
+          <children xmi:type="notation:Shape" xmi:id="_LFPJ0APIEeaXyaQL1WyV3A" type="FinalState_Shape">
+            <children xmi:type="notation:DecorationNode" xmi:id="_LFPJ0gPIEeaXyaQL1WyV3A" type="FinalState_FloatingNameLabel">
+              <layoutConstraint xmi:type="notation:Location" xmi:id="_LFPJ0wPIEeaXyaQL1WyV3A" x="25" y="3"/>
+            </children>
+            <children xmi:type="notation:DecorationNode" xmi:id="_LFPJ1APIEeaXyaQL1WyV3A" type="FinalState_StereotypeLabel">
+              <layoutConstraint xmi:type="notation:Location" xmi:id="_LFPw4APIEeaXyaQL1WyV3A" x="25" y="-10"/>
+            </children>
+            <element xmi:type="uml:FinalState" href="multijoin-forkjoin.uml#_LFC8kAPIEeaXyaQL1WyV3A"/>
+            <layoutConstraint xmi:type="notation:Bounds" xmi:id="_LFPJ0QPIEeaXyaQL1WyV3A" x="630" y="77"/>
+          </children>
+          <children xmi:type="notation:Shape" xmi:id="_YIMCwAPIEeaXyaQL1WyV3A" type="Pseudostate_ForkShape">
+            <children xmi:type="notation:DecorationNode" xmi:id="_YIMCwgPIEeaXyaQL1WyV3A" type="Pseudostate_ForkFloatingNameLabel">
+              <layoutConstraint xmi:type="notation:Location" xmi:id="_YIMCwwPIEeaXyaQL1WyV3A" y="-40"/>
+            </children>
+            <children xmi:type="notation:DecorationNode" xmi:id="_YIMCxAPIEeaXyaQL1WyV3A" type="Pseudostate_ForkStereotypeLabel">
+              <layoutConstraint xmi:type="notation:Location" xmi:id="_YIMCxQPIEeaXyaQL1WyV3A" x="25" y="-10"/>
+            </children>
+            <element xmi:type="uml:Pseudostate" href="multijoin-forkjoin.uml#_YIEuAAPIEeaXyaQL1WyV3A"/>
+            <layoutConstraint xmi:type="notation:Bounds" xmi:id="_YIMCwQPIEeaXyaQL1WyV3A" x="150" y="127"/>
+          </children>
+          <children xmi:type="notation:Shape" xmi:id="_a9e04APIEeaXyaQL1WyV3A" type="Pseudostate_JoinShape">
+            <children xmi:type="notation:DecorationNode" xmi:id="_a9e04gPIEeaXyaQL1WyV3A" type="Pseudostate_JoinFloatingNameLabel">
+              <layoutConstraint xmi:type="notation:Location" xmi:id="_a9e04wPIEeaXyaQL1WyV3A" y="-40"/>
+            </children>
+            <children xmi:type="notation:DecorationNode" xmi:id="_a9e05APIEeaXyaQL1WyV3A" type="Pseudostate_JoinStereotypeLabel">
+              <layoutConstraint xmi:type="notation:Location" xmi:id="_a9fb8APIEeaXyaQL1WyV3A" x="25" y="-10"/>
+            </children>
+            <element xmi:type="uml:Pseudostate" href="multijoin-forkjoin.uml#_a9XgIAPIEeaXyaQL1WyV3A"/>
+            <layoutConstraint xmi:type="notation:Bounds" xmi:id="_a9e04QPIEeaXyaQL1WyV3A" x="550" y="127"/>
+          </children>
+          <children xmi:type="notation:Shape" xmi:id="_f-AIcAPIEeaXyaQL1WyV3A" type="State_Shape">
+            <children xmi:type="notation:DecorationNode" xmi:id="_f-AIcgPIEeaXyaQL1WyV3A" type="State_NameLabel">
+              <layoutConstraint xmi:type="notation:Bounds" xmi:id="_h1M6oAPIEeaXyaQL1WyV3A" width="261" height="20"/>
+            </children>
+            <children xmi:type="notation:DecorationNode" xmi:id="_f-AIcwPIEeaXyaQL1WyV3A" type="State_FloatingNameLabel">
+              <layoutConstraint xmi:type="notation:Location" xmi:id="_f-AIdAPIEeaXyaQL1WyV3A" x="40"/>
+            </children>
+            <children xmi:type="notation:BasicCompartment" xmi:id="_44I7kVhbEea5u-C4k4QikQ" type="State_RegionCompartment">
+              <children xmi:type="notation:Shape" xmi:id="_iu90MAPIEeaXyaQL1WyV3A" type="Region_Shape">
+                <eAnnotations xmi:type="ecore:EAnnotation" xmi:id="_iu90NAPIEeaXyaQL1WyV3A" source="RegionAnnotationKey">
+                  <details xmi:type="ecore:EStringToStringMapEntry" xmi:id="_iu90NQPIEeaXyaQL1WyV3A" key="RegionZoneKey" value="T"/>
+                </eAnnotations>
+                <children xmi:type="notation:BasicCompartment" xmi:id="_44JioFhbEea5u-C4k4QikQ" type="Region_SubvertexCompartment">
+                  <children xmi:type="notation:Shape" xmi:id="_mL_UsAPIEeaXyaQL1WyV3A" type="State_Shape">
+                    <children xmi:type="notation:DecorationNode" xmi:id="_mL_UsgPIEeaXyaQL1WyV3A" type="State_NameLabel"/>
+                    <children xmi:type="notation:DecorationNode" xmi:id="_mL_UswPIEeaXyaQL1WyV3A" type="State_FloatingNameLabel">
+                      <layoutConstraint xmi:type="notation:Location" xmi:id="_mL_UtAPIEeaXyaQL1WyV3A" x="40"/>
+                    </children>
+                    <children xmi:type="notation:BasicCompartment" xmi:id="_44KJsFhbEea5u-C4k4QikQ" type="State_RegionCompartment">
+                      <layoutConstraint xmi:type="notation:Bounds" xmi:id="_mL_UtgPIEeaXyaQL1WyV3A"/>
+                    </children>
+                    <element xmi:type="uml:State" href="multijoin-forkjoin.uml#_mL08oAPIEeaXyaQL1WyV3A"/>
+                    <layoutConstraint xmi:type="notation:Bounds" xmi:id="_mL_UsQPIEeaXyaQL1WyV3A" x="80" y="17"/>
+                  </children>
+                  <children xmi:type="notation:Shape" xmi:id="_mkQDsAPIEeaXyaQL1WyV3A" type="State_Shape">
+                    <children xmi:type="notation:DecorationNode" xmi:id="_mkQDsgPIEeaXyaQL1WyV3A" type="State_NameLabel"/>
+                    <children xmi:type="notation:DecorationNode" xmi:id="_mkQDswPIEeaXyaQL1WyV3A" type="State_FloatingNameLabel">
+                      <layoutConstraint xmi:type="notation:Location" xmi:id="_mkQDtAPIEeaXyaQL1WyV3A" x="40"/>
+                    </children>
+                    <children xmi:type="notation:BasicCompartment" xmi:id="_44KJsVhbEea5u-C4k4QikQ" type="State_RegionCompartment">
+                      <layoutConstraint xmi:type="notation:Bounds" xmi:id="_mkQDtgPIEeaXyaQL1WyV3A"/>
+                    </children>
+                    <element xmi:type="uml:State" href="multijoin-forkjoin.uml#_mkFEkAPIEeaXyaQL1WyV3A"/>
+                    <layoutConstraint xmi:type="notation:Bounds" xmi:id="_mkQDsQPIEeaXyaQL1WyV3A" x="180" y="17"/>
+                  </children>
+                  <children xmi:type="notation:Shape" xmi:id="_55n88APIEeaXyaQL1WyV3A" type="Pseudostate_InitialShape">
+                    <children xmi:type="notation:DecorationNode" xmi:id="_55okAAPIEeaXyaQL1WyV3A" type="Pseudostate_InitialFloatingNameLabel">
+                      <layoutConstraint xmi:type="notation:Location" xmi:id="_55okAQPIEeaXyaQL1WyV3A" x="25" y="3"/>
+                    </children>
+                    <children xmi:type="notation:DecorationNode" xmi:id="_55okAgPIEeaXyaQL1WyV3A" type="Pseudostate_InitialStereotypeLabel">
+                      <layoutConstraint xmi:type="notation:Location" xmi:id="_55okAwPIEeaXyaQL1WyV3A" x="25" y="-10"/>
+                    </children>
+                    <element xmi:type="uml:Pseudostate" href="multijoin-forkjoin.uml#_55YFUAPIEeaXyaQL1WyV3A"/>
+                    <layoutConstraint xmi:type="notation:Bounds" xmi:id="_55n88QPIEeaXyaQL1WyV3A" x="20" y="17"/>
+                  </children>
+                  <layoutConstraint xmi:type="notation:Bounds" xmi:id="_iu90MwPIEeaXyaQL1WyV3A"/>
+                </children>
+                <element xmi:type="uml:Region" href="multijoin-forkjoin.uml#_iu8mEAPIEeaXyaQL1WyV3A"/>
+                <layoutConstraint xmi:type="notation:Bounds" xmi:id="_iu90MQPIEeaXyaQL1WyV3A" width="261" height="98"/>
+              </children>
+              <children xmi:type="notation:Shape" xmi:id="_j0iVIAPIEeaXyaQL1WyV3A" type="Region_Shape">
+                <eAnnotations xmi:type="ecore:EAnnotation" xmi:id="_j0iVJAPIEeaXyaQL1WyV3A" source="RegionAnnotationKey">
+                  <details xmi:type="ecore:EStringToStringMapEntry" xmi:id="_j0iVJQPIEeaXyaQL1WyV3A" key="RegionZoneKey" value="B"/>
+                </eAnnotations>
+                <children xmi:type="notation:BasicCompartment" xmi:id="_44KwwFhbEea5u-C4k4QikQ" type="Region_SubvertexCompartment">
+                  <children xmi:type="notation:Shape" xmi:id="_sraPMAPIEeaXyaQL1WyV3A" type="State_Shape">
+                    <children xmi:type="notation:DecorationNode" xmi:id="_sraPMgPIEeaXyaQL1WyV3A" type="State_NameLabel"/>
+                    <children xmi:type="notation:DecorationNode" xmi:id="_sraPMwPIEeaXyaQL1WyV3A" type="State_FloatingNameLabel">
+                      <layoutConstraint xmi:type="notation:Location" xmi:id="_sraPNAPIEeaXyaQL1WyV3A" x="40"/>
+                    </children>
+                    <children xmi:type="notation:BasicCompartment" xmi:id="_44LX0FhbEea5u-C4k4QikQ" type="State_RegionCompartment">
+                      <layoutConstraint xmi:type="notation:Bounds" xmi:id="_sraPNgPIEeaXyaQL1WyV3A"/>
+                    </children>
+                    <element xmi:type="uml:State" href="multijoin-forkjoin.uml#_srPQEAPIEeaXyaQL1WyV3A"/>
+                    <layoutConstraint xmi:type="notation:Bounds" xmi:id="_sraPMQPIEeaXyaQL1WyV3A" x="80" y="39"/>
+                  </children>
+                  <children xmi:type="notation:Shape" xmi:id="_tDMdEAPIEeaXyaQL1WyV3A" type="State_Shape">
+                    <children xmi:type="notation:DecorationNode" xmi:id="_tDNEIAPIEeaXyaQL1WyV3A" type="State_NameLabel"/>
+                    <children xmi:type="notation:DecorationNode" xmi:id="_tDNEIQPIEeaXyaQL1WyV3A" type="State_FloatingNameLabel">
+                      <layoutConstraint xmi:type="notation:Location" xmi:id="_tDNEIgPIEeaXyaQL1WyV3A" x="40"/>
+                    </children>
+                    <children xmi:type="notation:BasicCompartment" xmi:id="_44LX0VhbEea5u-C4k4QikQ" type="State_RegionCompartment">
+                      <layoutConstraint xmi:type="notation:Bounds" xmi:id="_tDNEJAPIEeaXyaQL1WyV3A"/>
+                    </children>
+                    <element xmi:type="uml:State" href="multijoin-forkjoin.uml#_tDCFAAPIEeaXyaQL1WyV3A"/>
+                    <layoutConstraint xmi:type="notation:Bounds" xmi:id="_tDMdEQPIEeaXyaQL1WyV3A" x="180" y="39"/>
+                  </children>
+                  <children xmi:type="notation:Shape" xmi:id="_7hRQMAPIEeaXyaQL1WyV3A" type="Pseudostate_InitialShape">
+                    <children xmi:type="notation:DecorationNode" xmi:id="_7hRQMgPIEeaXyaQL1WyV3A" type="Pseudostate_InitialFloatingNameLabel">
+                      <layoutConstraint xmi:type="notation:Location" xmi:id="_7hRQMwPIEeaXyaQL1WyV3A" x="25" y="3"/>
+                    </children>
+                    <children xmi:type="notation:DecorationNode" xmi:id="_7hRQNAPIEeaXyaQL1WyV3A" type="Pseudostate_InitialStereotypeLabel">
+                      <layoutConstraint xmi:type="notation:Location" xmi:id="_7hRQNQPIEeaXyaQL1WyV3A" x="25" y="-10"/>
+                    </children>
+                    <element xmi:type="uml:Pseudostate" href="multijoin-forkjoin.uml#_7hD00APIEeaXyaQL1WyV3A"/>
+                    <layoutConstraint xmi:type="notation:Bounds" xmi:id="_7hRQMQPIEeaXyaQL1WyV3A" x="20" y="59"/>
+                  </children>
+                  <layoutConstraint xmi:type="notation:Bounds" xmi:id="_j0iVIwPIEeaXyaQL1WyV3A"/>
+                </children>
+                <element xmi:type="uml:Region" href="multijoin-forkjoin.uml#_j0hHAAPIEeaXyaQL1WyV3A"/>
+                <layoutConstraint xmi:type="notation:Bounds" xmi:id="_j0iVIQPIEeaXyaQL1WyV3A" y="98" width="261" height="120"/>
+              </children>
+              <layoutConstraint xmi:type="notation:Bounds" xmi:id="_f-AIdgPIEeaXyaQL1WyV3A" y="20" width="261" height="218"/>
+            </children>
+            <element xmi:type="uml:State" href="multijoin-forkjoin.uml#_f92XcAPIEeaXyaQL1WyV3A"/>
+            <layoutConstraint xmi:type="notation:Bounds" xmi:id="_f-AIcQPIEeaXyaQL1WyV3A" x="230" y="27" width="261" height="238"/>
+          </children>
+          <children xmi:type="notation:Shape" xmi:id="__inPgFhbEea5u-C4k4QikQ" type="State_Shape">
+            <children xmi:type="notation:DecorationNode" xmi:id="__ipEsFhbEea5u-C4k4QikQ" type="State_NameLabel"/>
+            <children xmi:type="notation:DecorationNode" xmi:id="__ipEsVhbEea5u-C4k4QikQ" type="State_FloatingNameLabel">
+              <layoutConstraint xmi:type="notation:Location" xmi:id="__ipEslhbEea5u-C4k4QikQ" x="40"/>
+            </children>
+            <children xmi:type="notation:BasicCompartment" xmi:id="__iprwFhbEea5u-C4k4QikQ" type="State_RegionCompartment">
+              <layoutConstraint xmi:type="notation:Bounds" xmi:id="__iprwVhbEea5u-C4k4QikQ"/>
+            </children>
+            <element xmi:type="uml:State" href="multijoin-forkjoin.uml#__hywIFhbEea5u-C4k4QikQ"/>
+            <layoutConstraint xmi:type="notation:Bounds" xmi:id="__inPgVhbEea5u-C4k4QikQ" x="626" y="163"/>
+          </children>
+          <layoutConstraint xmi:type="notation:Bounds" xmi:id="_CsJ_CQPIEeaXyaQL1WyV3A"/>
+        </children>
+        <element xmi:type="uml:Region" href="multijoin-forkjoin.uml#_CsHiwAPIEeaXyaQL1WyV3A"/>
+        <layoutConstraint xmi:type="notation:Bounds" xmi:id="_CsJ_CgPIEeaXyaQL1WyV3A" width="834" height="290"/>
+      </children>
+      <layoutConstraint xmi:type="notation:Bounds" xmi:id="_CsJ_CwPIEeaXyaQL1WyV3A" y="20" width="834" height="290"/>
+    </children>
+    <element xmi:type="uml:StateMachine" href="multijoin-forkjoin.uml#_Cr6HYAPIEeaXyaQL1WyV3A"/>
+    <layoutConstraint xmi:type="notation:Bounds" xmi:id="_CsJ_DAPIEeaXyaQL1WyV3A" x="30" y="30" width="834" height="310"/>
+  </children>
+  <styles xmi:type="notation:StringValueStyle" xmi:id="_CsJ_DQPIEeaXyaQL1WyV3A" name="diagram_compatibility_version" stringValue="1.2.0"/>
+  <styles xmi:type="notation:DiagramStyle" xmi:id="_CsJ_DgPIEeaXyaQL1WyV3A"/>
+  <styles xmi:type="style:PapyrusViewStyle" xmi:id="_CsJ_DwPIEeaXyaQL1WyV3A">
+    <owner xmi:type="uml:Model" href="multijoin-forkjoin.uml#_CrssAAPIEeaXyaQL1WyV3A"/>
+  </styles>
+  <element xmi:type="uml:StateMachine" href="multijoin-forkjoin.uml#_Cr6HYAPIEeaXyaQL1WyV3A"/>
+  <edges xmi:type="notation:Connector" xmi:id="_9j8SkAPIEeaXyaQL1WyV3A" type="Transition_Edge" source="_IPcocAPIEeaXyaQL1WyV3A" target="_Iy1pYAPIEeaXyaQL1WyV3A">
+    <children xmi:type="notation:DecorationNode" xmi:id="_9j8SkwPIEeaXyaQL1WyV3A" type="Transition_NameLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_9j8SlAPIEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_9j8SlQPIEeaXyaQL1WyV3A" type="Transition_GuardLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_9j8SlgPIEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_9j85oAPIEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_9j85oQPIEeaXyaQL1WyV3A" y="60"/>
+    </children>
+    <styles xmi:type="notation:FontStyle" xmi:id="_9j8SkQPIEeaXyaQL1WyV3A"/>
+    <element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_9hO80APIEeaXyaQL1WyV3A"/>
+    <bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_9j8SkgPIEeaXyaQL1WyV3A" points="[8, 2, -39, 10]$[73, 39, 26, 47]"/>
+    <sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_9ko2IAPIEeaXyaQL1WyV3A" id="(1.0,0.65)"/>
+    <targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_9ko2IQPIEeaXyaQL1WyV3A" id="(0.0,0.06382978723404255)"/>
+  </edges>
+  <edges xmi:type="notation:Connector" xmi:id="_ADeQEAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_Iy1pYAPIEeaXyaQL1WyV3A" target="_YIMCwAPIEeaXyaQL1WyV3A">
+    <children xmi:type="notation:DecorationNode" xmi:id="_ADeQEwPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_ADeQFAPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_ADeQFQPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_ADeQFgPJEeaXyaQL1WyV3A" x="4" y="26"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_ADeQFwPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_ADeQGAPJEeaXyaQL1WyV3A" y="60"/>
+    </children>
+    <styles xmi:type="notation:FontStyle" xmi:id="_ADeQEQPJEeaXyaQL1WyV3A"/>
+    <element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_ADNKUAPJEeaXyaQL1WyV3A"/>
+    <bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_ADeQEgPJEeaXyaQL1WyV3A" points="[9, 5, -48, -31]$[59, 36, 2, 0]"/>
+    <sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_AEMBwAPJEeaXyaQL1WyV3A" id="(1.0,0.6382978723404256)"/>
+    <targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_AEMBwQPJEeaXyaQL1WyV3A" id="(0.0,0.375)"/>
+  </edges>
+  <edges xmi:type="notation:Connector" xmi:id="_D5uI4APJEeaXyaQL1WyV3A" type="Transition_Edge" source="_YIMCwAPIEeaXyaQL1WyV3A" target="_mL_UsAPIEeaXyaQL1WyV3A">
+    <children xmi:type="notation:DecorationNode" xmi:id="_D5uI4wPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_D5uI5APJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_D5uI5QPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_D5uI5gPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_D5uI5wPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_D5uI6APJEeaXyaQL1WyV3A" y="60"/>
+    </children>
+    <styles xmi:type="notation:FontStyle" xmi:id="_D5uI4QPJEeaXyaQL1WyV3A"/>
+    <element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_D5dDIAPJEeaXyaQL1WyV3A"/>
+    <bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_D5uI4gPJEeaXyaQL1WyV3A" points="[0, 0, -160, 60]$[200, -25, 40, 35]"/>
+    <sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_D6aFYAPJEeaXyaQL1WyV3A" id="(1.0,0.45)"/>
+    <targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_D6aFYQPJEeaXyaQL1WyV3A" id="(0.0,0.6595744680851063)"/>
+  </edges>
+  <edges xmi:type="notation:Connector" xmi:id="_FgR3AAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_YIMCwAPIEeaXyaQL1WyV3A" target="_sraPMAPIEeaXyaQL1WyV3A">
+    <children xmi:type="notation:DecorationNode" xmi:id="_FgR3AwPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_FgR3BAPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_FgR3BQPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_FgR3BgPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_FgR3BwPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_FgR3CAPJEeaXyaQL1WyV3A" y="60"/>
+    </children>
+    <styles xmi:type="notation:FontStyle" xmi:id="_FgR3AQPJEeaXyaQL1WyV3A"/>
+    <element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_FgAxQAPJEeaXyaQL1WyV3A"/>
+    <bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_FgR3AgPJEeaXyaQL1WyV3A" points="[10, 4, -150, -56]$[197, 103, 37, 43]"/>
+    <sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_Fg8lYAPJEeaXyaQL1WyV3A" id="(1.0,0.625)"/>
+    <targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_Fg8lYQPJEeaXyaQL1WyV3A" id="(0.0,0.46808510638297873)"/>
+  </edges>
+  <edges xmi:type="notation:Connector" xmi:id="_Hg0LYAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_55n88APIEeaXyaQL1WyV3A" target="_mL_UsAPIEeaXyaQL1WyV3A">
+    <children xmi:type="notation:DecorationNode" xmi:id="_Hg0ycAPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_Hg0ycQPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_Hg0ycgPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_Hg0ycwPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_Hg0ydAPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_Hg0ydQPJEeaXyaQL1WyV3A" y="60"/>
+    </children>
+    <styles xmi:type="notation:FontStyle" xmi:id="_Hg0LYQPJEeaXyaQL1WyV3A"/>
+    <element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_HgkTwAPJEeaXyaQL1WyV3A"/>
+    <bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_Hg0LYgPJEeaXyaQL1WyV3A" points="[8, 1, -52, 0]$[53, -8, -7, -9]"/>
+    <sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_Hhe5wAPJEeaXyaQL1WyV3A" id="(1.0,0.45)"/>
+    <targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_Hhe5wQPJEeaXyaQL1WyV3A" id="(0.0,0.2127659574468085)"/>
+  </edges>
+  <edges xmi:type="notation:Connector" xmi:id="_IOl3YAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_7hRQMAPIEeaXyaQL1WyV3A" target="_sraPMAPIEeaXyaQL1WyV3A">
+    <children xmi:type="notation:DecorationNode" xmi:id="_IOmecgPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_IOmecwPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_IOmedAPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_IOmedQPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_IOmedgPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_IOmedwPJEeaXyaQL1WyV3A" y="60"/>
+    </children>
+    <styles xmi:type="notation:FontStyle" xmi:id="_IOmecAPJEeaXyaQL1WyV3A"/>
+    <element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_IOTjgAPJEeaXyaQL1WyV3A"/>
+    <bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_IOmecQPJEeaXyaQL1WyV3A" points="[0, 9, -74, 0]$[76, 17, 2, 8]"/>
+    <sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_IPTCAAPJEeaXyaQL1WyV3A" id="(1.0,0.6)"/>
+    <targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_IPTCAQPJEeaXyaQL1WyV3A" id="(0.0,0.7659574468085106)"/>
+  </edges>
+  <edges xmi:type="notation:Connector" xmi:id="_KIIy8APJEeaXyaQL1WyV3A" type="Transition_Edge" source="_mL_UsAPIEeaXyaQL1WyV3A" target="_mkQDsAPIEeaXyaQL1WyV3A">
+    <children xmi:type="notation:DecorationNode" xmi:id="_KIIy8wPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_KIIy9APJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_KIIy9QPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_KIIy9gPJEeaXyaQL1WyV3A" x="-2" y="-13"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_KIIy9wPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_KIIy-APJEeaXyaQL1WyV3A" y="60"/>
+    </children>
+    <styles xmi:type="notation:FontStyle" xmi:id="_KIIy8QPJEeaXyaQL1WyV3A"/>
+    <element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_KH4UQAPJEeaXyaQL1WyV3A"/>
+    <bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_KIIy8gPJEeaXyaQL1WyV3A" points="[40, 10, -64, -16]$[100, 26, -4, 0]"/>
+    <sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_KIyTMAPJEeaXyaQL1WyV3A" id="(1.0,0.46808510638297873)"/>
+    <targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_KIyTMQPJEeaXyaQL1WyV3A" id="(0.0,0.5319148936170213)"/>
+  </edges>
+  <edges xmi:type="notation:Connector" xmi:id="_KwWpgAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_sraPMAPIEeaXyaQL1WyV3A" target="_tDMdEAPIEeaXyaQL1WyV3A">
+    <children xmi:type="notation:DecorationNode" xmi:id="_KwWpgwPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_KwWphAPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_KwWphQPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_KwWphgPJEeaXyaQL1WyV3A" x="1" y="-18"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_KwWphwPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_KwWpiAPJEeaXyaQL1WyV3A" y="60"/>
+    </children>
+    <styles xmi:type="notation:FontStyle" xmi:id="_KwWpgQPJEeaXyaQL1WyV3A"/>
+    <element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_KwInEAPJEeaXyaQL1WyV3A"/>
+    <bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_KwWpggPJEeaXyaQL1WyV3A" points="[40, 9, -67, -17]$[100, 27, -7, 1]"/>
+    <sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_KxAJwAPJEeaXyaQL1WyV3A" id="(1.0,0.6170212765957447)"/>
+    <targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_KxAJwQPJEeaXyaQL1WyV3A" id="(0.0,0.5531914893617021)"/>
+  </edges>
+  <edges xmi:type="notation:Connector" xmi:id="_MofP0APJEeaXyaQL1WyV3A" type="Transition_Edge" source="_mkQDsAPIEeaXyaQL1WyV3A" target="_a9e04APIEeaXyaQL1WyV3A">
+    <children xmi:type="notation:DecorationNode" xmi:id="_Mof24APJEeaXyaQL1WyV3A" type="Transition_NameLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_Mof24QPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_Mof24gPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_Mof24wPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_Mof25APJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_Mof25QPJEeaXyaQL1WyV3A" y="60"/>
+    </children>
+    <styles xmi:type="notation:FontStyle" xmi:id="_MofP0QPJEeaXyaQL1WyV3A"/>
+    <element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_MoM78APJEeaXyaQL1WyV3A"/>
+    <bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_MofP0gPJEeaXyaQL1WyV3A" points="[40, 24, -102, -62]$[140, 90, -2, 4]"/>
+    <sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_MpTvMAPJEeaXyaQL1WyV3A" id="(1.0,0.6170212765957447)"/>
+    <targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_MpTvMQPJEeaXyaQL1WyV3A" id="(0.0,0.6)"/>
+  </edges>
+  <edges xmi:type="notation:Connector" xmi:id="_NR4LEAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_tDMdEAPIEeaXyaQL1WyV3A" target="_a9e04APIEeaXyaQL1WyV3A">
+    <children xmi:type="notation:DecorationNode" xmi:id="_NR4yIAPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_NR4yIQPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_NR4yIgPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_NR4yIwPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_NR4yJAPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_NR4yJQPJEeaXyaQL1WyV3A" y="60"/>
+    </children>
+    <styles xmi:type="notation:FontStyle" xmi:id="_NR4LEQPJEeaXyaQL1WyV3A"/>
+    <element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_NRphkAPJEeaXyaQL1WyV3A"/>
+    <bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_NR4LEgPJEeaXyaQL1WyV3A" points="[40, 15, -103, 43]$[141, -20, -2, 8]"/>
+    <sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_NSiSYAPJEeaXyaQL1WyV3A" id="(1.0,0.2978723404255319)"/>
+    <targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_NSi5cAPJEeaXyaQL1WyV3A" id="(0.0,0.825)"/>
+  </edges>
+  <edges xmi:type="notation:Connector" xmi:id="_QKNDEAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_a9e04APIEeaXyaQL1WyV3A" target="_LFPJ0APIEeaXyaQL1WyV3A">
+    <children xmi:type="notation:DecorationNode" xmi:id="_QKNDEwPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
+      <styles xmi:type="notation:BooleanValueStyle" xmi:id="_DZ1YsFhcEea5u-C4k4QikQ" name="IS_UPDATED_POSITION" booleanValue="true"/>
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_QKNqIAPJEeaXyaQL1WyV3A"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_QKNqIQPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
+      <styles xmi:type="notation:BooleanValueStyle" xmi:id="_DaccsFhcEea5u-C4k4QikQ" name="IS_UPDATED_POSITION" booleanValue="true"/>
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_QKNqIgPJEeaXyaQL1WyV3A" x="5" y="9"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_QKNqIwPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
+      <styles xmi:type="notation:BooleanValueStyle" xmi:id="_DbHyIFhcEea5u-C4k4QikQ" name="IS_UPDATED_POSITION" booleanValue="true"/>
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_QKNqJAPJEeaXyaQL1WyV3A" y="59"/>
+    </children>
+    <styles xmi:type="notation:FontStyle" xmi:id="_QKNDEQPJEeaXyaQL1WyV3A"/>
+    <element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_QJ79UAPJEeaXyaQL1WyV3A"/>
+    <bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_QKNDEgPJEeaXyaQL1WyV3A" points="[10, 1, -80, -9]$[98, 10, 8, 0]"/>
+    <sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_QK6NsAPJEeaXyaQL1WyV3A" id="(1.0,0.525)"/>
+    <targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_QK6NsQPJEeaXyaQL1WyV3A" id="(0.0,0.55)"/>
+  </edges>
+  <edges xmi:type="notation:Connector" xmi:id="_IDiHsFhcEea5u-C4k4QikQ" type="Transition_Edge" source="_a9e04APIEeaXyaQL1WyV3A" target="__inPgFhbEea5u-C4k4QikQ">
+    <children xmi:type="notation:DecorationNode" xmi:id="_IDjV0FhcEea5u-C4k4QikQ" type="Transition_NameLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_IDjV0VhcEea5u-C4k4QikQ"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_IDjV0lhcEea5u-C4k4QikQ" type="Transition_GuardLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_IDjV01hcEea5u-C4k4QikQ" x="4" y="-16"/>
+    </children>
+    <children xmi:type="notation:DecorationNode" xmi:id="_IDjV1FhcEea5u-C4k4QikQ" type="Transition_StereotypeLabel">
+      <layoutConstraint xmi:type="notation:Location" xmi:id="_IDjV1VhcEea5u-C4k4QikQ" y="60"/>
+    </children>
+    <styles xmi:type="notation:FontStyle" xmi:id="_IDiHsVhcEea5u-C4k4QikQ"/>
+    <element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_IAzj0FhcEea5u-C4k4QikQ"/>
+    <bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_IDiHslhcEea5u-C4k4QikQ" points="[591, 206, -643984, -643984]$[657, 227, -643984, -643984]"/>
+    <sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_IFBVcFhcEea5u-C4k4QikQ" id="(1.0,0.725)"/>
+    <targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_IFB8gFhcEea5u-C4k4QikQ" id="(0.0,0.3181818181818182)"/>
+  </edges>
+</notation:Diagram>
diff --git a/spring-statemachine-uml/src/test/resources/org/springframework/statemachine/uml/multijoin-forkjoin.uml b/spring-statemachine-uml/src/test/resources/org/springframework/statemachine/uml/multijoin-forkjoin.uml
new file mode 100644
index 00000000..7f9ec2e4
--- /dev/null
+++ b/spring-statemachine-uml/src/test/resources/org/springframework/statemachine/uml/multijoin-forkjoin.uml
@@ -0,0 +1,63 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<uml:Model xmi:version="20131001" xmlns:xmi="http://www.omg.org/spec/XMI/20131001" xmlns:uml="http://www.eclipse.org/uml2/5.0.0/UML" xmi:id="_CrssAAPIEeaXyaQL1WyV3A" name="RootElement">
+  <packagedElement xmi:type="uml:StateMachine" xmi:id="_Cr6HYAPIEeaXyaQL1WyV3A" name="StateMachine">
+    <region xmi:type="uml:Region" xmi:id="_CsHiwAPIEeaXyaQL1WyV3A" name="Region1">
+      <transition xmi:type="uml:Transition" xmi:id="_9hO80APIEeaXyaQL1WyV3A" source="_IPSQYAPIEeaXyaQL1WyV3A" target="_IyviwAPIEeaXyaQL1WyV3A"/>
+      <transition xmi:type="uml:Transition" xmi:id="_ADNKUAPJEeaXyaQL1WyV3A" source="_IyviwAPIEeaXyaQL1WyV3A" target="_YIEuAAPIEeaXyaQL1WyV3A">
+        <trigger xmi:type="uml:Trigger" xmi:id="_lTnQUAPKEeaXyaQL1WyV3A" event="_Lej94APKEeaXyaQL1WyV3A"/>
+      </transition>
+      <transition xmi:type="uml:Transition" xmi:id="_D5dDIAPJEeaXyaQL1WyV3A" source="_YIEuAAPIEeaXyaQL1WyV3A" target="_mL08oAPIEeaXyaQL1WyV3A"/>
+      <transition xmi:type="uml:Transition" xmi:id="_FgAxQAPJEeaXyaQL1WyV3A" source="_YIEuAAPIEeaXyaQL1WyV3A" target="_srPQEAPIEeaXyaQL1WyV3A"/>
+      <transition xmi:type="uml:Transition" xmi:id="_QJ79UAPJEeaXyaQL1WyV3A" guard="_5xWWQFkxEea5u-C4k4QikQ" source="_a9XgIAPIEeaXyaQL1WyV3A" target="_LFC8kAPIEeaXyaQL1WyV3A">
+        <ownedRule xmi:type="uml:Constraint" xmi:id="_5xWWQFkxEea5u-C4k4QikQ">
+          <specification xmi:type="uml:OpaqueExpression" xmi:id="_5xWWQVkxEea5u-C4k4QikQ">
+            <language>spel</language>
+            <body>!extendedState.variables.isEmpty()</body>
+          </specification>
+        </ownedRule>
+      </transition>
+      <transition xmi:type="uml:Transition" xmi:id="_IAzj0FhcEea5u-C4k4QikQ" guard="_HRVekFk0Eea5u-C4k4QikQ" source="_a9XgIAPIEeaXyaQL1WyV3A" target="__hywIFhbEea5u-C4k4QikQ">
+        <ownedRule xmi:type="uml:Constraint" xmi:id="_HRVekFk0Eea5u-C4k4QikQ">
+          <specification xmi:type="uml:OpaqueExpression" xmi:id="_HRVekVk0Eea5u-C4k4QikQ">
+            <language>spel</language>
+            <body>extendedState.variables.isEmpty()</body>
+          </specification>
+        </ownedRule>
+      </transition>
+      <subvertex xmi:type="uml:Pseudostate" xmi:id="_IPSQYAPIEeaXyaQL1WyV3A"/>
+      <subvertex xmi:type="uml:State" xmi:id="_IyviwAPIEeaXyaQL1WyV3A" name="SI"/>
+      <subvertex xmi:type="uml:FinalState" xmi:id="_LFC8kAPIEeaXyaQL1WyV3A" name="SF"/>
+      <subvertex xmi:type="uml:Pseudostate" xmi:id="_YIEuAAPIEeaXyaQL1WyV3A" name="S1" kind="fork"/>
+      <subvertex xmi:type="uml:Pseudostate" xmi:id="_a9XgIAPIEeaXyaQL1WyV3A" name="S3" kind="join"/>
+      <subvertex xmi:type="uml:State" xmi:id="_f92XcAPIEeaXyaQL1WyV3A" name="S2">
+        <region xmi:type="uml:Region" xmi:id="_iu8mEAPIEeaXyaQL1WyV3A" name="Region1">
+          <transition xmi:type="uml:Transition" xmi:id="_HgkTwAPJEeaXyaQL1WyV3A" source="_55YFUAPIEeaXyaQL1WyV3A" target="_mL08oAPIEeaXyaQL1WyV3A"/>
+          <transition xmi:type="uml:Transition" xmi:id="_KH4UQAPJEeaXyaQL1WyV3A" source="_mL08oAPIEeaXyaQL1WyV3A" target="_mkFEkAPIEeaXyaQL1WyV3A">
+            <trigger xmi:type="uml:Trigger" xmi:id="_pahbUAPKEeaXyaQL1WyV3A" event="_OEQ00APKEeaXyaQL1WyV3A"/>
+          </transition>
+          <transition xmi:type="uml:Transition" xmi:id="_MoM78APJEeaXyaQL1WyV3A" source="_mkFEkAPIEeaXyaQL1WyV3A" target="_a9XgIAPIEeaXyaQL1WyV3A"/>
+          <subvertex xmi:type="uml:State" xmi:id="_mL08oAPIEeaXyaQL1WyV3A" name="S20"/>
+          <subvertex xmi:type="uml:State" xmi:id="_mkFEkAPIEeaXyaQL1WyV3A" name="S21"/>
+          <subvertex xmi:type="uml:Pseudostate" xmi:id="_55YFUAPIEeaXyaQL1WyV3A"/>
+        </region>
+        <region xmi:type="uml:Region" xmi:id="_j0hHAAPIEeaXyaQL1WyV3A" name="Region2">
+          <transition xmi:type="uml:Transition" xmi:id="_IOTjgAPJEeaXyaQL1WyV3A" source="_7hD00APIEeaXyaQL1WyV3A" target="_srPQEAPIEeaXyaQL1WyV3A"/>
+          <transition xmi:type="uml:Transition" xmi:id="_KwInEAPJEeaXyaQL1WyV3A" source="_srPQEAPIEeaXyaQL1WyV3A" target="_tDCFAAPIEeaXyaQL1WyV3A">
+            <trigger xmi:type="uml:Trigger" xmi:id="_r52kgAPKEeaXyaQL1WyV3A" event="_Qc11wAPKEeaXyaQL1WyV3A"/>
+          </transition>
+          <transition xmi:type="uml:Transition" xmi:id="_NRphkAPJEeaXyaQL1WyV3A" source="_tDCFAAPIEeaXyaQL1WyV3A" target="_a9XgIAPIEeaXyaQL1WyV3A"/>
+          <subvertex xmi:type="uml:State" xmi:id="_srPQEAPIEeaXyaQL1WyV3A" name="S30"/>
+          <subvertex xmi:type="uml:State" xmi:id="_tDCFAAPIEeaXyaQL1WyV3A" name="S31"/>
+          <subvertex xmi:type="uml:Pseudostate" xmi:id="_7hD00APIEeaXyaQL1WyV3A"/>
+        </region>
+      </subvertex>
+      <subvertex xmi:type="uml:State" xmi:id="__hywIFhbEea5u-C4k4QikQ" name="S4"/>
+    </region>
+  </packagedElement>
+  <packagedElement xmi:type="uml:Signal" xmi:id="_EqiFUAPKEeaXyaQL1WyV3A" name="E1"/>
+  <packagedElement xmi:type="uml:Signal" xmi:id="_GO8eYAPKEeaXyaQL1WyV3A" name="E2"/>
+  <packagedElement xmi:type="uml:Signal" xmi:id="_JdNxMAPKEeaXyaQL1WyV3A" name="E3"/>
+  <packagedElement xmi:type="uml:SignalEvent" xmi:id="_Lej94APKEeaXyaQL1WyV3A" name="SignalEventE1" signal="_EqiFUAPKEeaXyaQL1WyV3A"/>
+  <packagedElement xmi:type="uml:SignalEvent" xmi:id="_OEQ00APKEeaXyaQL1WyV3A" name="SignalEventE2" signal="_GO8eYAPKEeaXyaQL1WyV3A"/>
+  <packagedElement xmi:type="uml:SignalEvent" xmi:id="_Qc11wAPKEeaXyaQL1WyV3A" name="SignalEventE3" signal="_JdNxMAPKEeaXyaQL1WyV3A"/>
+</uml:Model>