diff options
| author |   Snigdha Sucharita Patra <sp00503415@techmahindra.com> | 2018-02-15 13:35:56 +0530 |
|---|---|---|
| committer | Snigdha Sucharita Patra <sp00503415@techmahindra.com> | 2018-02-15 13:35:56 +0530 |
| commit | 2ab54626327d49813a30f7d59de2af1b4085d700 (patch) | |
| tree | 1cf397040d4866b4c00e37efa31b03a3d48cc69c /dcae-analytics-cdap-plugins/src/main/java/org | |
| parent | 1a0595e1953c7b745186f7c534f8e348428ac74a (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/org')
| -rw-r--r-- | dcae-analytics-cdap-plugins/src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/streaming/dmaap/MockDMaaPMRReceiver.java | 1 |
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); } |