diff options
Diffstat (limited to 'models-interactions/model-impl/cds/src')
| -rw-r--r-- | models-interactions/model-impl/cds/src/main/java/org/onap/policy/cds/client/CdsProcessorHandler.java | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/models-interactions/model-impl/cds/src/main/java/org/onap/policy/cds/client/CdsProcessorHandler.java b/models-interactions/model-impl/cds/src/main/java/org/onap/policy/cds/client/CdsProcessorHandler.java index 84baecdf1..04b584081 100644 --- a/models-interactions/model-impl/cds/src/main/java/org/onap/policy/cds/client/CdsProcessorHandler.java +++ b/models-interactions/model-impl/cds/src/main/java/org/onap/policy/cds/client/CdsProcessorHandler.java @@ -35,8 +35,8 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class CdsProcessorHandler { - private static final Logger LOGGER = LoggerFactory.getLogger(CdsProcessorHandler.class); + private static final String LOG_MSG = "[{}|{}|{}|]{}{}"; private CdsProcessorListener listener; private String url; @@ -56,8 +56,8 @@ public class CdsProcessorHandler { final StreamObserver<ExecutionServiceOutput> responseObserver = new StreamObserver<ExecutionServiceOutput>() { @Override public void onNext(ExecutionServiceOutput output) { - LOGGER.info("[{}|{}|{}|]{}{}", EventType.IN, CommInfrastructure.REST, url, NetLoggerUtil.SYSTEM_LS, - output.toString()); + LOGGER.info(LOG_MSG, EventType.IN, CommInfrastructure.REST, url, NetLoggerUtil.SYSTEM_LS, + output); NetLoggerUtil.log(EventType.IN, CommInfrastructure.REST, url, output.toString()); listener.onMessage(output); @@ -65,8 +65,8 @@ public class CdsProcessorHandler { @Override public void onError(Throwable throwable) { - LOGGER.info("[{}|{}|{}|]{}{}", EventType.IN, CommInfrastructure.REST, url, NetLoggerUtil.SYSTEM_LS, - throwable.toString()); + LOGGER.info(LOG_MSG, EventType.IN, CommInfrastructure.REST, url, NetLoggerUtil.SYSTEM_LS, + throwable); NetLoggerUtil.log(EventType.IN, CommInfrastructure.REST, url, throwable.toString()); listener.onError(throwable); finishLatch.countDown(); @@ -82,8 +82,8 @@ public class CdsProcessorHandler { final StreamObserver<ExecutionServiceInput> requestObserver = asyncStub.process(responseObserver); try { - LOGGER.info("[{}|{}|{}|]{}{}", EventType.OUT, CommInfrastructure.REST, url, NetLoggerUtil.SYSTEM_LS, - request.toString()); + LOGGER.info(LOG_MSG, EventType.OUT, CommInfrastructure.REST, url, NetLoggerUtil.SYSTEM_LS, + request); NetLoggerUtil.log(EventType.OUT, CommInfrastructure.REST, url, request.toString()); // Send the message to CDS backend for processing |