@Test(expected = ConfigException.class)
public void testEmptyStreamsParam() throws Exception {

    Map<String, String> map = new HashMap<String, String>();
    map.put("rico.es.streams", "");
    ESPushTaskConfig.getStreamMap(new MapConfig(map));
}