aboutsummaryrefslogtreecommitdiffstats
path: root/dmaap-listener/src/main/java
diff options
context:
space:
mode:
authorArindam Mondal <arind.mondal@samsung.com>2018-07-10 15:11:38 +0900
committerONAP <arind.mondal@samsung.com>2018-07-10 15:39:58 +0900
commit16ecee44bc14dcb0a128cfdabf0ae8b17f1db057 (patch)
tree24c8d7336bdbcf6dc4212a95b633590df9585fd1 /dmaap-listener/src/main/java
parentb13fc8a9b134c43a437d7a48ceb509295df4713a (diff)
Sonar issue fix blocker, critical
Issue-ID: CCSDK-332 Change-Id: I8741cb5bf68d71f0376105d2b1683ac05534a001 Signed-off-by: Arindam Mondal <arind.mondal@samsung.com>
Diffstat (limited to 'dmaap-listener/src/main/java')
-rw-r--r--dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/MessageRouterHttpClient.java1
-rw-r--r--dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/MessageRouterHttpClientJdk.java1
2 files changed, 2 insertions, 0 deletions
diff --git a/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/MessageRouterHttpClient.java b/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/MessageRouterHttpClient.java
index 13146e4e..c02ec5df 100644
--- a/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/MessageRouterHttpClient.java
+++ b/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/MessageRouterHttpClient.java
@@ -97,6 +97,7 @@ public class MessageRouterHttpClient implements SdncDmaapConsumer {
Thread.sleep(fetchPause);
} catch (InterruptedException e) {
Log.error("Could not sleep thread", e);
+ Thread.currentThread().interrupt();
}
}
}
diff --git a/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/MessageRouterHttpClientJdk.java b/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/MessageRouterHttpClientJdk.java
index 3336b81f..a6744045 100644
--- a/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/MessageRouterHttpClientJdk.java
+++ b/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/MessageRouterHttpClientJdk.java
@@ -111,6 +111,7 @@ public class MessageRouterHttpClientJdk implements SdncDmaapConsumer {
Thread.sleep(fetchPause);
} catch (InterruptedException e) {
Log.error("Could not sleep thread", e);
+ Thread.currentThread().interrupt();
}
}
}