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>

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();
 		}