This commit is contained in:
Janne Valkealahti
2015-10-11 11:51:59 +01:00
parent fe530f9db2
commit 4df80adc4f

View File

@@ -361,7 +361,7 @@ public class TasksHandlerTests {
.build();
TestListener listener = new TestListener();
listener.reset(10, 0, 0);
listener.reset(12, 0, 0);
StateMachine<String, String> machine = handler.getStateMachine();
machine.addStateListener(listener);
machine.start();
@@ -372,8 +372,8 @@ public class TasksHandlerTests {
handler.runTasks();
assertThat(listener.stateChangedLatch.await(8, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(10));
assertThat(machine.getState().getIds(), contains(TasksHandler.STATE_ERROR, TasksHandler.STATE_AUTOMATIC));
assertThat(listener.stateChangedCount, is(12));
assertThat(machine.getState().getIds(), contains(TasksHandler.STATE_ERROR, TasksHandler.STATE_MANUAL));
Map<Object, Object> variables = machine.getExtendedState().getVariables();
assertThat(variables.size(), is(3));