@Test
public void testAddRecord() throws Exception {

    // Setup:
    Record record = recordFactory.createNew(NEW_IRI);
    record.setProperty(USER_IRI, VALUE_FACTORY.createIRI(_Thing.publisher_IRI));
    manager.addRecord(distributedCatalogId, record);
    verify(utilsService).getObject(eq(distributedCatalogId), eq(catalogFactory), any(RepositoryConnection.class));
    verify(utilsService).addObject(eq(record), any(RepositoryConnection.class));
    assertTrue(record.getCatalog_resource().isPresent());
    assertEquals(distributedCatalogId, record.getCatalog_resource().get());
}