@Test
public void testSetCatalogFramework() {

  CatalogFramework catalogFramework = mock(CatalogFramework.class);
  udpStreamMonitor.setCatalogFramework(catalogFramework);
  verify(udpStreamProcessor).setCatalogFramework(catalogFramework);
}