summaryrefslogtreecommitdiffstats
path: root/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java
diff options
context:
space:
mode:
Diffstat (limited to 'policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java')
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java13
1 files changed, 3 insertions, 10 deletions
diff --git a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java
index cf89762a..293bf608 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/TopicEndpointProxy.java
@@ -24,6 +24,7 @@ import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Properties;
+import lombok.Getter;
import org.onap.policy.common.capabilities.Startable;
import org.onap.policy.common.endpoints.event.comm.bus.DmaapTopicFactories;
import org.onap.policy.common.endpoints.event.comm.bus.DmaapTopicSink;
@@ -53,11 +54,13 @@ class TopicEndpointProxy implements TopicEndpoint {
/**
* Is this element locked boolean.
*/
+ @Getter
private volatile boolean locked = false;
/**
* Is this element alive boolean.
*/
+ @Getter
private volatile boolean alive = false;
@Override
@@ -435,11 +438,6 @@ class TopicEndpointProxy implements TopicEndpoint {
}
@Override
- public boolean isAlive() {
- return this.alive;
- }
-
- @Override
public boolean lock() {
boolean shouldLock;
@@ -484,11 +482,6 @@ class TopicEndpointProxy implements TopicEndpoint {
}
@Override
- public boolean isLocked() {
- return this.locked;
- }
-
- @Override
public TopicSource getTopicSource(Topic.CommInfrastructure commType, String topicName) {
if (commType == null) {