@Test
public void testStatusHandling() throws Exception {

	new Context() {{
		startResourceManager();
		// Verify that the RM forwards status updates to the launch coordinator and task router.
		resourceManager.statusUpdate(new StatusUpdate(Protos.TaskStatus.newBuilder()
			.setTaskId(task1).setSlaveId(slave1).setState(Protos.TaskState.TASK_LOST).build()));
		resourceManager.reconciliationCoordinator.expectMsgClass(StatusUpdate.class);
		resourceManager.taskRouter.expectMsgClass(StatusUpdate.class);
	}};
}