From cc4897a71480906b33e1c27d1b48b5a9017f86aa Mon Sep 17 00:00:00 2001 From: Krzysztof Opasiak Date: Wed, 30 Jan 2019 19:55:20 +0100 Subject: Return true only if thread has been really started Accortding to doc start() should return true if start operation was successful. Unfortunately value of this.alive may change between end of synchronized block and return for example when other thread executes stop() in parallel. Change-Id: I4103f0f4c65620c47b4acf2d276f104937b91187 Issue-ID: POLICY-1387 Signed-off-by: Krzysztof Opasiak --- .../event/comm/bus/internal/SingleThreadedBusTopicSource.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'policy-endpoints') diff --git a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedBusTopicSource.java b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedBusTopicSource.java index 4cc8fbb1..83f3760b 100644 --- a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedBusTopicSource.java +++ b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedBusTopicSource.java @@ -172,6 +172,7 @@ public abstract class SingleThreadedBusTopicSource extends BusTopicBase this.busPollerThread = makePollerThread(); this.busPollerThread.setName(this.getTopicCommInfrastructure() + "-source-" + this.getTopic()); busPollerThread.start(); + return true; } catch (Exception e) { logger.warn("{}: cannot start because of {}", this, e.getMessage(), e); throw new IllegalStateException(e); @@ -179,7 +180,7 @@ public abstract class SingleThreadedBusTopicSource extends BusTopicBase } } - return this.alive; + return false; } /** -- cgit 1.2.3-korg