summaryrefslogtreecommitdiffstats
path: root/policy-core
diff options
context:
space:
mode:
Diffstat (limited to 'policy-core')
-rw-r--r--policy-core/src/main/java/org/onap/policy/drools/core/PolicySession.java9
1 files changed, 5 insertions, 4 deletions
diff --git a/policy-core/src/main/java/org/onap/policy/drools/core/PolicySession.java b/policy-core/src/main/java/org/onap/policy/drools/core/PolicySession.java
index 389d5b37..fb17b10a 100644
--- a/policy-core/src/main/java/org/onap/policy/drools/core/PolicySession.java
+++ b/policy-core/src/main/java/org/onap/policy/drools/core/PolicySession.java
@@ -1,8 +1,8 @@
/*
* ============LICENSE_START=======================================================
- * policy-core
+ * ONAP
* ================================================================================
- * Copyright (C) 2017-2020 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2021 AT&T Intellectual Property. All rights reserved.
* Modifications Copyright (C) 2018 Samsung Electronics Co., Ltd.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
@@ -469,8 +469,9 @@ public class PolicySession
// one more interrupt, just in case the 'kieSession.halt()'
// didn't work for some reason
thread.interrupt();
- } catch (Exception e) {
+ } catch (InterruptedException e) {
logger.error("stopThread in thread.join error", e);
+ Thread.currentThread().interrupt();
}
}
@@ -497,7 +498,7 @@ public class PolicySession
// We want to continue looping, despite any exceptions that occur
// while rules are fired.
- KieSession kieSession1 = session.getKieSession();
+ var kieSession1 = session.getKieSession();
while (repeat) {
try {
kieSession1.fireUntilHalt();