@Test(expected = NullPointerException.class) public void roadHasNoMatchingVersion() { Road road = new Road(schemas); roads.put(ROAD_NAME, road); Schema result = underTest.getSchema(2); assertThat(result, is(schema1)); }
@Override public Schema getSchema(int version) { return roads.get(roadName).getSchemas().get(version).getSchema(); }
KafkaStoreSchemaLookup implements SchemaLookup { @Override public Schema getSchema(int version) { return roads.get(roadName).getSchemas().get(version).getSchema(); } }
KafkaStoreSchemaLookup implements SchemaLookup { @Override public Schema getSchema(int version) { return roads.get(roadName).getSchemas().get(version).getSchema(); } @Autowired  KafkaStoreSchemaLookup(Map<String, Road> roads, @Value("${road.name}") String roadName); }
KafkaStoreSchemaLookup implements SchemaLookup { @Override public Schema getSchema(int version) { return roads.get(roadName).getSchemas().get(version).getSchema(); } @Autowired  KafkaStoreSchemaLookup(Map<String, Road> roads, @Value("${road.name}") String roadName); @Override Schema getSchema(int version); }
KafkaStoreSchemaLookup implements SchemaLookup { @Override public Schema getSchema(int version) { return roads.get(roadName).getSchemas().get(version).getSchema(); } @Autowired  KafkaStoreSchemaLookup(Map<String, Road> roads, @Value("${road.name}") String roadName); @Override Schema getSchema(int version);  }