summaryrefslogtreecommitdiffstats
path: root/policy-endpoints/src/main/java/org
diff options
context:
space:
mode:
authorJorge Hernandez <jh1730@att.com>2017-11-30 10:12:33 -0600
committerJorge Hernandez <jh1730@att.com>2017-11-30 10:12:33 -0600
commitcbe3fbc728f0428dc339f0b43c2afed163e9ffa7 (patch)
tree2e51df09b81a95e1938deece812085f3a3f92d08 /policy-endpoints/src/main/java/org
parent46f1e7e0f4a916af93c82be907433813664c75b5 (diff)
make volatile access to alive and locked flags
instead of synchronized read access Change-Id: I3f4457f798d6f4d4a013bf023ed2d9c1b75d4f1f Issue-ID: POLICY-487 Signed-off-by: Jorge Hernandez <jh1730@att.com>
Diffstat (limited to 'policy-endpoints/src/main/java/org')
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusPublisher.java6
1 files changed, 1 insertions, 5 deletions
diff --git a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusPublisher.java b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusPublisher.java
index 10bc8325..ad5a9179 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusPublisher.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusPublisher.java
@@ -139,10 +139,7 @@ public interface BusPublisher {
@Override
public String toString() {
StringBuilder builder = new StringBuilder();
- builder.append("CambriaPublisherWrapper [").
- append("publisher.getPendingMessageCount()=").
- append(publisher.getPendingMessageCount()).
- append("]");
+ builder.append("CambriaPublisherWrapper []");
return builder.toString();
}
@@ -289,7 +286,6 @@ public interface BusPublisher {
append(", publisher.getHost()=").append(publisher.getHost()).
append(", publisher.getProtocolFlag()=").append(publisher.getProtocolFlag()).
append(", publisher.getUsername()=").append(publisher.getUsername()).
- append(", publisher.getPendingMessageCount()=").append(publisher.getPendingMessageCount()).
append("]");
return builder.toString();
}