summaryrefslogtreecommitdiffstats
path: root/dcae-analytics-cdap-plugins/src/main/java
diff options
context:
space:
mode:
authorSnigdha Sucharita Patra <sp00503415@techmahindra.com>2018-02-15 13:35:56 +0530
committerSnigdha Sucharita Patra <sp00503415@techmahindra.com>2018-02-15 13:35:56 +0530
commit2ab54626327d49813a30f7d59de2af1b4085d700 (patch)
tree1cf397040d4866b4c00e37efa31b03a3d48cc69c /dcae-analytics-cdap-plugins/src/main/java
parent1a0595e1953c7b745186f7c534f8e348428ac74a (diff)
sonar critical issue
Either re-interrupt this method or rethrow the InterruptedException Sonar Link: https://sonar.onap.org/project/issues?assignees=Snigdha503415&id=org.onap.dcaegen2.analytics.tca%3Adcae-analytics&open=AWFSducGof9FJ6jfXJfg&resolved=false&severities=CRITICAL Location: src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/streaming/dmaap/MockDMaaPMRReceiver.java Line No-117 Change-Id: Iaa2d2147081682040411c2d88a6b81413507e489 Issue-ID: DCAEGEN2-344 Signed-off-by: Snigdha Sucharita Patra <sp00503415@techmahindra.com>
Diffstat (limited to 'dcae-analytics-cdap-plugins/src/main/java')
-rw-r--r--dcae-analytics-cdap-plugins/src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/streaming/dmaap/MockDMaaPMRReceiver.java1
1 files changed, 1 insertions, 0 deletions
diff --git a/dcae-analytics-cdap-plugins/src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/streaming/dmaap/MockDMaaPMRReceiver.java b/dcae-analytics-cdap-plugins/src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/streaming/dmaap/MockDMaaPMRReceiver.java
index f4f781a..2b6ad84 100644
--- a/dcae-analytics-cdap-plugins/src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/streaming/dmaap/MockDMaaPMRReceiver.java
+++ b/dcae-analytics-cdap-plugins/src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/streaming/dmaap/MockDMaaPMRReceiver.java
@@ -116,6 +116,7 @@ public class MockDMaaPMRReceiver extends Receiver<StructuredRecord> {
TimeUnit.MILLISECONDS.sleep(pluginConfig.getPollingInterval());
} catch (InterruptedException e) {
LOG.error("Error while sleeping");
+ Thread.currentThread().interrupt();
throw new DCAEAnalyticsRuntimeException("Error while sleeping", LOG, e);
}