@Test(expected = NotConnectedException.class)
public void testOpen_withExceptionAndRetries() throws Exception {

    chatConfig.sourceConnectionSleepIntervalMs = 1000;
    chatConfig.sourceConnectionMaxMs = 1000;
    stormConf.put(ConfigurationConstants.CHATALYTICS_CONFIG.txt, YamlUtils.writeYaml(config));
    try {
        underTest.open(stormConf, mockContext, mockCollector);
        fail();
    } catch (Exception e) {
        throw (Exception) e.getCause();
    }
}