Add Some Log Printing
[holmes/engine-management.git] / engine-d / src / main / java / org / onap / holmes / engine / dmaap / DMaaPAlarmPolling.java
1 /*
2  * Copyright 2017 ZTE Corporation.
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  * http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 package org.onap.holmes.engine.dmaap;
17
18 import java.util.ArrayList;
19 import java.util.List;
20 import lombok.extern.slf4j.Slf4j;
21 import org.onap.holmes.common.api.stat.VesAlarm;
22 import org.onap.holmes.common.exception.CorrelationException;
23 import org.onap.holmes.dsa.dmaappolling.Subscriber;
24 import org.onap.holmes.engine.manager.DroolsEngine;
25
26 @Slf4j
27 public class DMaaPAlarmPolling implements Runnable {
28
29     private Subscriber subscriber;
30     private DroolsEngine droolsEngine;
31     private volatile boolean isAlive = true;
32
33     public DMaaPAlarmPolling(Subscriber subscriber, DroolsEngine droolsEngine) {
34         this.subscriber = subscriber;
35         this.droolsEngine = droolsEngine;
36     }
37
38     public void run() {
39         while (isAlive) {
40             List<VesAlarm> vesAlarmList = new ArrayList<>();
41             try {
42                 vesAlarmList = subscriber.subscribe();
43                 vesAlarmList.forEach(vesAlarm -> droolsEngine.putRaisedIntoStream(vesAlarm));
44             } catch (CorrelationException e) {
45                 log.error("Failed polling request alarm. " + e.getMessage());
46             } catch (Exception e) {
47                 log.error("An error occurred while processing alarm.", e);
48             }
49         }
50     }
51
52     public void stopTask() {
53         isAlive = false;
54     }
55 }