diff options
Diffstat (limited to 'controlloop/m2/lock')
| -rw-r--r-- | controlloop/m2/lock/src/main/java/org/onap/policy/drools/m2/lock/LockAdjunct.java | 13 |
1 files changed, 4 insertions, 9 deletions
diff --git a/controlloop/m2/lock/src/main/java/org/onap/policy/drools/m2/lock/LockAdjunct.java b/controlloop/m2/lock/src/main/java/org/onap/policy/drools/m2/lock/LockAdjunct.java index e81ab6288..98d82876e 100644 --- a/controlloop/m2/lock/src/main/java/org/onap/policy/drools/m2/lock/LockAdjunct.java +++ b/controlloop/m2/lock/src/main/java/org/onap/policy/drools/m2/lock/LockAdjunct.java @@ -21,7 +21,6 @@ package org.onap.policy.drools.m2.lock; import java.io.Serializable; -import java.util.HashMap; import org.onap.policy.drools.core.lock.Lock; import org.onap.policy.drools.core.lock.LockCallback; @@ -103,14 +102,10 @@ public class LockAdjunct implements Transaction.Adjunct, LockCallback, this.requestor = requestor; // try to allocate a new lock - if ((lock = PolicyEngineConstants.getManager().createLock( - key, ownerKey, 600, this, waitForLock)).isActive()) { - // the lock is good - return true; - } - - // we need to wait for the lock -- return false, - return false; + lock = PolicyEngineConstants.getManager().createLock( + key, ownerKey, 600, this, waitForLock); + // return the boolean value of the lock.isactive + return lock.isActive(); } /*=================================*/ |