*/
package org.onap.holmes.engine.dmaap;
+import static jdk.nashorn.internal.runtime.regexp.joni.Config.log;
+
import java.util.ArrayList;
import java.util.List;
import lombok.extern.slf4j.Slf4j;
List<VesAlarm> vesAlarmList = new ArrayList<>();
try {
vesAlarmList = subscriber.subscribe();
+ vesAlarmList.forEach(vesAlarm -> droolsEngine.putRaisedIntoStream(vesAlarm));
} catch (CorrelationException e) {
- log.error("Failed polling request alarm. " + e.getMessage());
+ log.error("Failed to process alarms. Sleep for 60 seconds to restart.", e);
+ try {
+ Thread.sleep(60000);
+ } catch (InterruptedException e1) {
+ log.info("Thread is still active.", e);
+ }
+ } catch (Exception e) {
+ log.error("An error occurred while processing alarm. Sleep for 60 seconds to restart.", e);
+ try {
+ Thread.sleep(60000);
+ } catch (InterruptedException e1) {
+ log.info("Thread is still active.", e);
+ }
}
- vesAlarmList.forEach(vesAlarm -> droolsEngine.putRaisedIntoStream(vesAlarm));
}
}