Spring/spring-statemachine
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add synchronization

Browse Source 
- Relates to #135
This commit is contained in:
Janne Valkealahti
2015-12-30 10:55:56 +00:00
parent 7395b6afcd
commit 5227aea34b
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-statemachine-core/src/main/java/org/springframework/statemachine/support/AbstractStateMachine.java
View File

@@ -570,7 +570,7 @@ public abstract class AbstractStateMachine<S, E> extends StateMachineObjectSuppo
return id;
}
protected boolean acceptEvent(Message<E> message) {
protected synchronized boolean acceptEvent(Message<E> message) {
if ((currentState != null && currentState.shouldDefer(message))) {
log.info("Current state " + currentState + " deferred event " + message);
stateMachineExecutor.queueDeferredEvent(message);
@@ -704,7 +704,7 @@ public abstract class AbstractStateMachine<S, E> extends StateMachineObjectSuppo
return null;
}
void setCurrentState(State<S, E> state, Message<E> message, Transition<S, E> transition, boolean exit, StateMachine<S, E> stateMachine) {
synchronized void setCurrentState(State<S, E> state, Message<E> message, Transition<S, E> transition, boolean exit, StateMachine<S, E> stateMachine) {
State<S, E> findDeep = findDeepParent(state);
boolean isTargetSubOf = false;