- List<VesAlarm> vesAlarmList = new ArrayList<>();
- try {
- vesAlarmList = subscriber.subscribe();
- } catch (CorrelationException e) {
- log.error("Failed polling request alarm." + e.getMessage());
+ while (isAlive) {
+ List<VesAlarm> vesAlarmList = new ArrayList<>();
+ try {
+ vesAlarmList = subscriber.subscribe();
+ } catch (CorrelationException e) {
+ log.error("Failed polling request alarm." + e.getMessage());
+ }
+ vesAlarmList.forEach(vesAlarm -> droolsEngine.putRaisedIntoStream(vesAlarm));