@Test
public void schemaCreated() throws Exception {

  underTest.handleSchemaCreated(ROAD_NAME, SCHEMA_VERSION);
  ArgumentCaptor<DataHighwayNotification> captor = ArgumentCaptor.forClass(DataHighwayNotification.class);
  verify(notificationHandler).send(captor.capture());
  SchemaVersionAdded notification = (SchemaVersionAdded) captor.getValue();
  assertThat(notification.getSchemaVersion(), is(SCHEMA_VERSION));
  assertThat(notification.getType(), is(RoadNotificationType.SCHEMA_VERSION_ADDED));
}