summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-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);
}