1 files changed, 2 insertions, 0 deletions

diff --git a/services/services-engine/src/main/java/org/onap/policy/apex/service/engine/runtime/impl/EngineWorker.java b/services/services-engine/src/main/java/org/onap/policy/apex/service/engine/runtime/impl/EngineWorker.java
index 20f8aaf75..f74c0f47b 100644
--- a/services/services-engine/src/main/java/org/onap/policy/apex/service/engine/runtime/impl/EngineWorker.java
+++ b/services/services-engine/src/main/java/org/onap/policy/apex/service/engine/runtime/impl/EngineWorker.java
@@ -649,6 +649,8 @@ final class EngineWorker implements EngineService {
                 try {
                     event = eventProcessingQueue.take();
                 } catch (final InterruptedException e) {
+                    // restore the interrupt status
+                    Thread.currentThread().interrupt();
                     LOGGER.debug("Engine {} processing interrupted ", engineWorkerKey);
                     break;
                 }