7374757677787980818283
message, context, currentStateDelta, executor); executor.scheduleTask(message, handler, context); while (!executor.isDone(msgId + "/" + message.getPartitionName())) { Thread.sleep(500); } AssertJUnit.assertTrue(stateModel.stateModelInvoked);