@Test
public void inspectRoad_corrects_road_type() throws Exception {

  KafkaRoad model = new KafkaRoad("test_road", "road.test_road", RoadType.NORMAL,
      new TrafficControlStatus(true, 6, 3, ""), null, false);
  given(kafkaAdminClient.topicExists("road.test_road")).willReturn(true);
  given(kafkaAdminClient.topicDetails("road.test_road")).willReturn(new KafkaTopicDetails(RoadType.COMPACT, 6, 3));
  List<PatchOperation> operations = trafficControl.inspectModel("test_road", model);
  assertThat(operations.size(), is(1));
  assertThat(operations.get(0).getOperation(), is(Operation.ADD));
  assertThat(operations.get(0).getPath(), is("/type"));
  assertThat(operations.get(0).getValue(), is(RoadType.COMPACT));
}