From cbe3fbc728f0428dc339f0b43c2afed163e9ffa7 Mon Sep 17 00:00:00 2001 From: Jorge Hernandez Date: Thu, 30 Nov 2017 10:12:33 -0600 Subject: 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 --- .../onap/policy/drools/event/comm/bus/internal/BusPublisher.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) (limited to 'policy-endpoints/src') 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(); } -- cgit 1.2.3-korg