@Test
public void testStatusHandling() {

	new Context() {{
		new Within(duration("10 seconds")) {
			@Override
			protected void run() {
				initialize();
				register(Collections.<ResourceID>emptyList());
				// Verify that the RM forwards status updates to the launch coordinator and task router.
				resourceManager.tell(new StatusUpdate(Protos.TaskStatus.newBuilder()
					.setTaskId(task1).setSlaveId(slave1).setState(Protos.TaskState.TASK_LOST).build()),
					resourceManager);
				resourceManagerInstance.reconciliationCoordinator.expectMsgClass(StatusUpdate.class);
				resourceManagerInstance.taskRouter.expectMsgClass(StatusUpdate.class);
			}
		};
	}};
}