Reduce verbosity of logging during unit test

Logging dialled back in logback.xml files and on ligging statements in
unit test java code.

Issue-ID: POLICY-2272
Change-Id: I3b9a46d8993b1571c8dc62687a9c136af46c1f51
Signed-off-by: liamfallon <liam.fallon@est.tech>

10 files changed, 162 insertions, 137 deletions

diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/events/EventGenerator.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/events/EventGenerator.java
index 6a585d7c5..55b9fa953 100644
--- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/events/EventGenerator.java
+++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/events/EventGenerator.java
@@ -5,15 +5,15 @@
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *      http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
- * 
+ *
  * SPDX-License-Identifier: Apache-2.0
  * ============LICENSE_END=========================================================
  */
@@ -22,12 +22,17 @@ package org.onap.policy.apex.testsuites.integration.uservice.adapt.events;
 
 import java.util.Random;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 /**
  * The Class EventGenerator.
  *
  * @author Liam Fallon (liam.fallon@ericsson.com)
  */
 public class EventGenerator {
+    private static final Logger LOGGER = LoggerFactory.getLogger(EventGenerator.class);
+
     private static int nextEventNo = 0;
 
     /**
@@ -576,7 +581,7 @@ public class EventGenerator {
      */
     public static void main(final String[] args) {
         if (args.length != 2) {
-            System.err.println("usage EventGenerator #events XML|JSON");
+            LOGGER.error("usage EventGenerator #events XML|JSON");
             return;
         }
 
@@ -584,17 +589,17 @@ public class EventGenerator {
         try {
             eventCount = Integer.parseInt(args[0]);
         } catch (final Exception e) {
-            System.err.println("usage EventGenerator #events XML|JSON");
+            LOGGER.error("usage EventGenerator #events XML|JSON");
             e.printStackTrace();
             return;
         }
 
         if (args[1].equalsIgnoreCase("XML")) {
-            System.out.println(xmlEvents(eventCount));
+            LOGGER.info(xmlEvents(eventCount));
         } else if (args[1].equalsIgnoreCase("JSON")) {
-            System.out.println(jsonEvents(eventCount));
+            LOGGER.info(jsonEvents(eventCount));
         } else {
-            System.err.println("usage EventGenerator #events XML|JSON");
+            LOGGER.error("usage EventGenerator #events XML|JSON");
             return;
         }
     }
diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/jms/JmsEventProducer.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/jms/JmsEventProducer.java
index dcec4a944..7367b0220 100644
--- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/jms/JmsEventProducer.java
+++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/jms/JmsEventProducer.java
@@ -68,8 +68,8 @@ public class JmsEventProducer implements Runnable {
      * @throws JMSException the JMS exception
      */
     public JmsEventProducer(final String topic, final ConnectionFactory connectionFactory, final String username,
-            final String password, final int eventCount, final boolean sendObjects, final long eventInterval)
-            throws JMSException {
+                    final String password, final int eventCount, final boolean sendObjects, final long eventInterval)
+                    throws JMSException {
         this.topic = topic;
         this.eventCount = eventCount;
         this.sendObjects = sendObjects;
@@ -88,7 +88,7 @@ public class JmsEventProducer implements Runnable {
     public void run() {
         final Topic jmsTopic = new ActiveMQTopic(topic);
         try (final Session jmsSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-                final MessageProducer jmsProducer = jmsSession.createProducer(jmsTopic)) {
+                        final MessageProducer jmsProducer = jmsSession.createProducer(jmsTopic)) {
 
             while (producerThread.isAlive() && !stopFlag) {
                 ThreadUtilities.sleep(50);
@@ -120,8 +120,8 @@ public class JmsEventProducer implements Runnable {
      */
     private void sendEventsToTopic(final Session jmsSession, final MessageProducer jmsProducer) throws JMSException {
 
-        LOGGER.info("{} : sending events to JMS server, event count {}", this.getClass().getCanonicalName(),
-                eventCount);
+        LOGGER.debug("{} : sending events to JMS server, event count {}", this.getClass().getCanonicalName(),
+                        eventCount);
 
         for (int i = 0; i < eventCount; i++) {
             ThreadUtilities.sleep(eventInterval);
@@ -135,7 +135,7 @@ public class JmsEventProducer implements Runnable {
             jmsProducer.send(jmsMessage);
             eventsSentCount++;
         }
-        LOGGER.info("{} : completed, number of events sent", this.getClass().getCanonicalName(), eventsSentCount);
+        LOGGER.debug("{} : completed, number of events sent", this.getClass().getCanonicalName(), eventsSentCount);
     }
 
     /**
@@ -151,13 +151,13 @@ public class JmsEventProducer implements Runnable {
      * Shutdown.
      */
     public void shutdown() {
-        LOGGER.info("{} : stopping", this.getClass().getCanonicalName());
+        LOGGER.debug("{} : stopping", this.getClass().getCanonicalName());
         stopFlag = true;
 
         while (producerThread.isAlive()) {
             ThreadUtilities.sleep(10);
         }
-        LOGGER.info("{} : stopped", this.getClass().getCanonicalName());
+        LOGGER.debug("{} : stopped", this.getClass().getCanonicalName());
     }
 
 }
diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/jms/JmsEventSubscriber.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/jms/JmsEventSubscriber.java
index 94155c1a5..2fd174651 100644
--- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/jms/JmsEventSubscriber.java
+++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/jms/JmsEventSubscriber.java
@@ -106,7 +106,7 @@ public class JmsEventSubscriber implements Runnable {
             throw new ApexEventRuntimeException("JMS event consumption failed", e);
         }
 
-        LOGGER.info("{} : event reception completed", this.getClass().getCanonicalName());
+        LOGGER.debug("{} : event reception completed", this.getClass().getCanonicalName());
     }
 
     /**
@@ -131,7 +131,7 @@ public class JmsEventSubscriber implements Runnable {
         }
 
         connection.close();
-        LOGGER.info("{} : stopped", this.getClass().getCanonicalName());
+        LOGGER.debug("{} : stopped", this.getClass().getCanonicalName());
     }
 
 }
diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventProducer.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventProducer.java
index dd46f7f74..e0f5c23c4 100644
--- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventProducer.java
+++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventProducer.java
@@ -29,6 +29,8 @@ import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.StringSerializer;
 import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities;
 import org.onap.policy.apex.testsuites.integration.uservice.adapt.events.EventGenerator;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * The Class KafkaEventProducer.
@@ -36,6 +38,9 @@ import org.onap.policy.apex.testsuites.integration.uservice.adapt.events.EventGe
  * @author Liam Fallon (liam.fallon@ericsson.com)
  */
 public class KafkaEventProducer implements Runnable {
+    // Get a reference to the logger
+    private static final Logger LOGGER = LoggerFactory.getLogger(KafkaEventProducer.class);
+
     private final String topic;
     private final SharedKafkaTestResource sharedKafkaTestResource;
     private final int eventCount;
@@ -101,12 +106,12 @@ public class KafkaEventProducer implements Runnable {
      * @param producer the producer
      */
     private void sendEventsToTopic(final Producer<String, String> producer) {
-        System.out.println(KafkaEventProducer.class.getCanonicalName()
-                        + ": sending events to Kafka server , event count " + eventCount + ", xmlEvents " + xmlEvents);
+        LOGGER.debug("{} : sending events to Kafka server, event count {}, xmlEvents {}",
+                        KafkaEventProducer.class.getCanonicalName(), eventCount, xmlEvents);
 
         for (int i = 0; i < eventCount; i++) {
-            System.out.println(KafkaEventProducer.class.getCanonicalName() + ": waiting " + eventInterval
-                            + " milliseconds before sending next event");
+            LOGGER.debug("{} : waiting {} milliseconds before sending next event",
+                            KafkaEventProducer.class.getCanonicalName(), eventInterval);
             ThreadUtilities.sleep(eventInterval);
 
             String eventString = null;
@@ -118,9 +123,9 @@ public class KafkaEventProducer implements Runnable {
             producer.send(new ProducerRecord<String, String>(topic, "Event" + i + "Of" + eventCount, eventString));
             producer.flush();
             eventsSentCount++;
-            System.out.println("****** Sent event No. " + eventsSentCount + " ******");
+            LOGGER.debug("****** Sent event No. {} ******", eventsSentCount);
         }
-        System.out.println(KafkaEventProducer.class.getCanonicalName() + ": completed");
+        LOGGER.debug("{}: completed", KafkaEventProducer.class.getCanonicalName());
     }
 
     /**
@@ -136,7 +141,7 @@ public class KafkaEventProducer implements Runnable {
      * Shutdown.
      */
     public void shutdown() {
-        System.out.println(KafkaEventProducer.class.getCanonicalName() + ": stopping");
+        LOGGER.debug("{} : stopping", KafkaEventProducer.class.getCanonicalName());
 
         stopFlag = true;
 
@@ -144,6 +149,6 @@ public class KafkaEventProducer implements Runnable {
             ThreadUtilities.sleep(10);
         }
 
-        System.out.println(KafkaEventProducer.class.getCanonicalName() + ": stopped");
+        LOGGER.debug("{} : stopped", KafkaEventProducer.class.getCanonicalName());
     }
 }
diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java
index dbe8d0294..da2cc3344 100644
--- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java
+++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java
@@ -32,6 +32,8 @@ import org.apache.kafka.clients.consumer.KafkaConsumer;
 import org.apache.kafka.common.serialization.StringDeserializer;
 import org.onap.policy.apex.core.infrastructure.messaging.MessagingException;
 import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * The Class KafkaEventSubscriber.
@@ -39,6 +41,9 @@ import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities;
  * @author Liam Fallon (liam.fallon@ericsson.com)
  */
 public class KafkaEventSubscriber implements Runnable {
+    // Get a reference to the logger
+    private static final Logger LOGGER = LoggerFactory.getLogger(KafkaEventSubscriber.class);
+
     private static final Duration POLL_DURATION = Duration.ofMillis(100);
 
     private final String topic;
@@ -59,11 +64,9 @@ public class KafkaEventSubscriber implements Runnable {
                     throws MessagingException {
         this.topic = topic;
 
-
         final Properties consumerProperties = new Properties();
         consumerProperties.put("group.id", "test");
 
-
         consumer = sharedKafkaTestResource.getKafkaTestUtils().getKafkaConsumer(StringDeserializer.class,
                         StringDeserializer.class, consumerProperties);
         consumer.subscribe(Arrays.asList(topic));
@@ -77,17 +80,16 @@ public class KafkaEventSubscriber implements Runnable {
      */
     @Override
     public void run() {
-        System.out.println(KafkaEventSubscriber.class.getCanonicalName()
-                        + ": receiving events from Kafka server  on topic " + topic);
+        LOGGER.debug("{}: receiving events from Kafka server  on topic {}",
+                        KafkaEventSubscriber.class.getCanonicalName(), topic);
 
         while (subscriberThread.isAlive() && !subscriberThread.isInterrupted()) {
             try {
                 final ConsumerRecords<String, String> records = consumer.poll(POLL_DURATION);
                 for (final ConsumerRecord<String, String> record : records) {
                     eventsReceivedCount++;
-                    System.out.println("****** Received event No. " + eventsReceivedCount + " ******");
-                    System.out.println("offset=" + record.offset());
-                    System.out.println("key=" + record.key());
+                    LOGGER.debug("****** Received event No. {} ******\noffset={}\nkey={}", eventsReceivedCount,
+                                    record.offset(), record.key());
                 }
             } catch (final Exception e) {
                 // Thread interrupted
@@ -95,7 +97,7 @@ public class KafkaEventSubscriber implements Runnable {
             }
         }
 
-        System.out.println(KafkaEventSubscriber.class.getCanonicalName() + ": event reception completed");
+        LOGGER.debug("{}: event reception completed", KafkaEventSubscriber.class.getCanonicalName());
     }
 
     /**
@@ -118,6 +120,6 @@ public class KafkaEventSubscriber implements Runnable {
         }
 
         consumer.close();
-        System.out.println(KafkaEventSubscriber.class.getCanonicalName() + ": stopped");
+        LOGGER.debug("{} : stopped", KafkaEventSubscriber.class.getCanonicalName());
     }
 }
diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventProducerClient.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventProducerClient.java
index 46973290a..023ff9998 100644
--- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventProducerClient.java
+++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventProducerClient.java
@@ -5,15 +5,15 @@
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *      http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
- * 
+ *
  * SPDX-License-Identifier: Apache-2.0
  * ============LICENSE_END=========================================================
  */
@@ -25,11 +25,15 @@ import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStri
 import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageListener;
 import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities;
 import org.onap.policy.apex.testsuites.integration.uservice.adapt.events.EventGenerator;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * The Class WebSocketEventProducerClient.
  */
 public class WebSocketEventProducerClient implements WsStringMessageListener {
+    private static final Logger LOGGER = LoggerFactory.getLogger(WebSocketEventProducerClient.class);
+
     private final String host;
     private final int port;
     private final int eventCount;
@@ -50,7 +54,7 @@ public class WebSocketEventProducerClient implements WsStringMessageListener {
      * @throws MessagingException the messaging exception
      */
     public WebSocketEventProducerClient(final String host, final int port, final int eventCount,
-            final boolean xmlEvents, final long eventInterval) throws MessagingException {
+                    final boolean xmlEvents, final long eventInterval) throws MessagingException {
         this.host = host;
         this.port = port;
         this.eventCount = eventCount;
@@ -60,20 +64,20 @@ public class WebSocketEventProducerClient implements WsStringMessageListener {
         client = new WsStringMessageClient(host, port);
         client.start(this);
 
-        System.out.println(WebSocketEventProducerClient.class.getCanonicalName() + ": host " + host + ", port " + port
-                + ", event count " + eventCount + ", xmlEvents " + xmlEvents);
+        LOGGER.debug("{}: host {}, port {}, event count {}, xmlEvents {}",
+                        WebSocketEventProducerClient.class.getCanonicalName(), host, port, eventCount, xmlEvents);
     }
 
     /**
      * Send events.
      */
     public void sendEvents() {
-        System.out.println(WebSocketEventProducerClient.class.getCanonicalName() + ": sending events on host " + host
-                + ", port " + port + ", event count " + eventCount + ", xmlEvents " + xmlEvents);
+        LOGGER.debug("{}: sending events on host {}, port {}, event count {}, xmlEvents {}",
+                        WebSocketEventProducerClient.class.getCanonicalName(), host, port, eventCount, xmlEvents);
 
         for (int i = 0; i < eventCount; i++) {
-            System.out.println(WebSocketEventProducerClient.class.getCanonicalName() + ": waiting " + eventInterval
-                    + " milliseconds before sending next event");
+            LOGGER.debug("{}: waiting {} milliseconds before sending next event",
+                            WebSocketEventProducerClient.class.getCanonicalName(), eventInterval);
             ThreadUtilities.sleep(eventInterval);
 
             String eventString = null;
@@ -84,10 +88,10 @@ public class WebSocketEventProducerClient implements WsStringMessageListener {
             }
             client.sendString(eventString);
             eventsSentCount++;
-            System.out.println(WebSocketEventProducerClient.class.getCanonicalName() + ":  host " + host + ", port "
-                    + port + ", sent event " + eventString);
+            LOGGER.debug("{}:  host {}, port {}, sent event {}", WebSocketEventProducerClient.class.getCanonicalName(),
+                            host, port, eventString);
         }
-        System.out.println(WebSocketEventProducerClient.class.getCanonicalName() + ": completed");
+        LOGGER.debug("{}: completed", WebSocketEventProducerClient.class.getCanonicalName());
     }
 
     /**
@@ -104,7 +108,7 @@ public class WebSocketEventProducerClient implements WsStringMessageListener {
      */
     public void shutdown() {
         client.stop();
-        System.out.println(WebSocketEventProducerClient.class.getCanonicalName() + ": stopped");
+        LOGGER.debug("{}: stopped", WebSocketEventProducerClient.class.getCanonicalName());
     }
 
     /**
@@ -112,8 +116,8 @@ public class WebSocketEventProducerClient implements WsStringMessageListener {
      */
     @Override
     public void receiveString(final String eventString) {
-        System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ":  host " + host + ", port " + port
-                + ", received event " + eventString);
+        LOGGER.debug("{}:  host {}, port {}, received event {}", WebSocketEventProducerServer.class.getCanonicalName(),
+                        host, port, eventString);
     }
 
     /**
@@ -124,7 +128,7 @@ public class WebSocketEventProducerClient implements WsStringMessageListener {
      */
     public static void main(final String[] args) throws MessagingException {
         if (args.length != 5) {
-            System.err.println("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
+            LOGGER.error("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
             return;
         }
 
@@ -132,7 +136,7 @@ public class WebSocketEventProducerClient implements WsStringMessageListener {
         try {
             port = Integer.parseInt(args[1]);
         } catch (final Exception e) {
-            System.err.println("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
+            LOGGER.error("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
             e.printStackTrace();
             return;
         }
@@ -141,7 +145,7 @@ public class WebSocketEventProducerClient implements WsStringMessageListener {
         try {
             eventCount = Integer.parseInt(args[2]);
         } catch (final Exception e) {
-            System.err.println("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
+            LOGGER.error("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
             e.printStackTrace();
             return;
         }
@@ -150,7 +154,7 @@ public class WebSocketEventProducerClient implements WsStringMessageListener {
         try {
             eventInterval = Long.parseLong(args[4]);
         } catch (final Exception e) {
-            System.err.println("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
+            LOGGER.error("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
             e.printStackTrace();
             return;
         }
@@ -159,12 +163,12 @@ public class WebSocketEventProducerClient implements WsStringMessageListener {
         if (args[3].equalsIgnoreCase("XML")) {
             xmlEvents = true;
         } else if (!args[3].equalsIgnoreCase("JSON")) {
-            System.err.println("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
+            LOGGER.error("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
             return;
         }
 
-        final WebSocketEventProducerClient client =
-                new WebSocketEventProducerClient(args[0], port, eventCount, xmlEvents, eventInterval);
+        final WebSocketEventProducerClient client = new WebSocketEventProducerClient(args[0], port, eventCount,
+                        xmlEvents, eventInterval);
 
         client.sendEvents();
         client.shutdown();
diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventProducerServer.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventProducerServer.java
index b75d99ff0..11438d952 100644
--- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventProducerServer.java
+++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventProducerServer.java
@@ -5,15 +5,15 @@
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *      http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
- * 
+ *
  * SPDX-License-Identifier: Apache-2.0
  * ============LICENSE_END=========================================================
  */
@@ -25,11 +25,15 @@ import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStri
 import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageServer;
 import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities;
 import org.onap.policy.apex.testsuites.integration.uservice.adapt.events.EventGenerator;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * The Class WebSocketEventProducerServer.
  */
 public class WebSocketEventProducerServer implements WsStringMessageListener {
+    private static final Logger LOGGER = LoggerFactory.getLogger(WebSocketEventProducerServer.class);
+
     private final int port;
     private final int eventCount;
     private final boolean xmlEvents;
@@ -48,7 +52,7 @@ public class WebSocketEventProducerServer implements WsStringMessageListener {
      * @throws MessagingException the messaging exception
      */
     public WebSocketEventProducerServer(final int port, final int eventCount, final boolean xmlEvents,
-            final long eventInterval) throws MessagingException {
+                    final long eventInterval) throws MessagingException {
         this.port = port;
         this.eventCount = eventCount;
         this.xmlEvents = xmlEvents;
@@ -57,20 +61,20 @@ public class WebSocketEventProducerServer implements WsStringMessageListener {
         server = new WsStringMessageServer(port);
         server.start(this);
 
-        System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": port " + port + ", event count "
-                + eventCount + ", xmlEvents " + xmlEvents);
+        LOGGER.debug("{}: port {}, event count {}, xmlEvents {}", WebSocketEventProducerServer.class.getCanonicalName(),
+                        port, eventCount, xmlEvents);
     }
 
     /**
      * Send events.
      */
     public void sendEvents() {
-        System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": sending events on port " + port
-                + ", event count " + eventCount + ", xmlEvents " + xmlEvents);
+        LOGGER.debug("{}: sending events on port {}, event count {}, xmlEvents {}",
+                        WebSocketEventProducerServer.class.getCanonicalName(), port, eventCount, xmlEvents);
 
         for (int i = 0; i < eventCount; i++) {
-            System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": waiting " + eventInterval
-                    + " milliseconds before sending next event");
+            LOGGER.debug("{}: waiting {} milliseconds before sending next event",
+                            WebSocketEventProducerServer.class.getCanonicalName(), eventInterval);
             ThreadUtilities.sleep(eventInterval);
 
             String eventString = null;
@@ -81,11 +85,11 @@ public class WebSocketEventProducerServer implements WsStringMessageListener {
             }
             server.sendString(eventString);
             eventsSentCount++;
-            System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": port " + port
-                    + ", sent event " + eventString);
+            LOGGER.debug("{}: port {}, sent event {}", WebSocketEventProducerServer.class.getCanonicalName(), port,
+                            eventString);
         }
 
-        System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": event sending completed");
+        LOGGER.debug("{}: event sending completed", WebSocketEventProducerServer.class.getCanonicalName());
     }
 
     /**
@@ -102,7 +106,7 @@ public class WebSocketEventProducerServer implements WsStringMessageListener {
      */
     public void shutdown() {
         server.stop();
-        System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": stopped");
+        LOGGER.debug("{}: stopped", WebSocketEventProducerServer.class.getCanonicalName());
     }
 
     /**
@@ -110,8 +114,8 @@ public class WebSocketEventProducerServer implements WsStringMessageListener {
      */
     @Override
     public void receiveString(final String eventString) {
-        System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": port " + port
-                + ", received event " + eventString);
+        LOGGER.debug("{}: port {}, received event {}", WebSocketEventProducerServer.class.getCanonicalName(), port,
+                        eventString);
     }
 
     /**
@@ -122,7 +126,7 @@ public class WebSocketEventProducerServer implements WsStringMessageListener {
      */
     public static void main(final String[] args) throws MessagingException {
         if (args.length != 4) {
-            System.err.println("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
+            LOGGER.error("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
             return;
         }
 
@@ -130,7 +134,7 @@ public class WebSocketEventProducerServer implements WsStringMessageListener {
         try {
             port = Integer.parseInt(args[0]);
         } catch (final Exception e) {
-            System.err.println("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
+            LOGGER.error("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
             e.printStackTrace();
             return;
         }
@@ -139,7 +143,7 @@ public class WebSocketEventProducerServer implements WsStringMessageListener {
         try {
             eventCount = Integer.parseInt(args[1]);
         } catch (final Exception e) {
-            System.err.println("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
+            LOGGER.error("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
             e.printStackTrace();
             return;
         }
@@ -148,7 +152,7 @@ public class WebSocketEventProducerServer implements WsStringMessageListener {
         try {
             eventInterval = Long.parseLong(args[3]);
         } catch (final Exception e) {
-            System.err.println("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
+            LOGGER.error("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
             e.printStackTrace();
             return;
         }
@@ -157,12 +161,12 @@ public class WebSocketEventProducerServer implements WsStringMessageListener {
         if (args[2].equalsIgnoreCase("XML")) {
             xmlEvents = true;
         } else if (!args[2].equalsIgnoreCase("JSON")) {
-            System.err.println("usage WebSocketEventProducerServer port #events XML|JSON startDelay eventInterval");
+            LOGGER.error("usage WebSocketEventProducerServer port #events XML|JSON startDelay eventInterval");
             return;
         }
 
-        final WebSocketEventProducerServer server =
-                new WebSocketEventProducerServer(port, eventCount, xmlEvents, eventInterval);
+        final WebSocketEventProducerServer server = new WebSocketEventProducerServer(port, eventCount, xmlEvents,
+                        eventInterval);
 
         server.sendEvents();
         server.shutdown();
diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventSubscriberClient.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventSubscriberClient.java
index fab51529a..5cd871225 100644
--- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventSubscriberClient.java
+++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventSubscriberClient.java
@@ -5,15 +5,15 @@
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *      http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
- * 
+ *
  * SPDX-License-Identifier: Apache-2.0
  * ============LICENSE_END=========================================================
  */
@@ -23,11 +23,15 @@ package org.onap.policy.apex.testsuites.integration.uservice.adapt.websocket;
 import org.onap.policy.apex.core.infrastructure.messaging.MessagingException;
 import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageClient;
 import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageListener;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * The Class WebSocketEventSubscriberClient.
  */
 public class WebSocketEventSubscriberClient implements WsStringMessageListener {
+    private static final Logger LOGGER = LoggerFactory.getLogger(WebSocketEventSubscriberClient.class);
+
     private final int port;
     private long eventsReceivedCount = 0;
 
@@ -52,8 +56,8 @@ public class WebSocketEventSubscriberClient implements WsStringMessageListener {
      */
     @Override
     public void receiveString(final String eventString) {
-        System.out.println(WebSocketEventSubscriberClient.class.getCanonicalName() + ": port " + port
-                + ", received event " + eventString);
+        LOGGER.debug("{}: port {}, received event {}", WebSocketEventSubscriberClient.class.getCanonicalName(), port,
+                        eventString);
         eventsReceivedCount++;
     }
 
@@ -71,7 +75,7 @@ public class WebSocketEventSubscriberClient implements WsStringMessageListener {
      */
     public void shutdown() {
         client.stop();
-        System.out.println(WebSocketEventSubscriberServer.class.getCanonicalName() + ": stopped");
+        LOGGER.debug("{}: stopped", WebSocketEventSubscriberServer.class.getCanonicalName());
     }
 
     /**
@@ -82,7 +86,7 @@ public class WebSocketEventSubscriberClient implements WsStringMessageListener {
      */
     public static void main(final String[] args) throws MessagingException {
         if (args.length != 2) {
-            System.err.println("usage WebSocketEventSubscriberClient host port");
+            LOGGER.error("usage WebSocketEventSubscriberClient host port");
             return;
         }
 
@@ -90,7 +94,7 @@ public class WebSocketEventSubscriberClient implements WsStringMessageListener {
         try {
             port = Integer.parseInt(args[0]);
         } catch (final Exception e) {
-            System.err.println("usage WebSocketEventSubscriberClient port");
+            LOGGER.error("usage WebSocketEventSubscriberClient port");
             e.printStackTrace();
             return;
         }
diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventSubscriberServer.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventSubscriberServer.java
index edd6d7961..48d221791 100644
--- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventSubscriberServer.java
+++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/websocket/WebSocketEventSubscriberServer.java
@@ -5,15 +5,15 @@
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *      http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
- * 
+ *
  * SPDX-License-Identifier: Apache-2.0
  * ============LICENSE_END=========================================================
  */
@@ -23,11 +23,15 @@ package org.onap.policy.apex.testsuites.integration.uservice.adapt.websocket;
 import org.onap.policy.apex.core.infrastructure.messaging.MessagingException;
 import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageListener;
 import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageServer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * The Class WebSocketEventSubscriberServer.
  */
 public class WebSocketEventSubscriberServer implements WsStringMessageListener {
+    private static final Logger LOGGER = LoggerFactory.getLogger(WebSocketEventSubscriberServer.class);
+
     private final int port;
     private long eventsReceivedCount = 0;
 
@@ -45,8 +49,7 @@ public class WebSocketEventSubscriberServer implements WsStringMessageListener {
         server = new WsStringMessageServer(port);
         server.start(this);
 
-        System.out.println(
-                WebSocketEventSubscriberServer.class.getCanonicalName() + ": port " + port + ", waiting for events");
+        LOGGER.debug("{}: port {}, waiting for events", WebSocketEventSubscriberServer.class.getCanonicalName(), port);
     }
 
     /**
@@ -54,8 +57,8 @@ public class WebSocketEventSubscriberServer implements WsStringMessageListener {
      */
     @Override
     public void receiveString(final String eventString) {
-        System.out.println(WebSocketEventSubscriberServer.class.getCanonicalName() + ": port " + port
-                + ", received event " + eventString);
+        LOGGER.debug("{}: port {}, received event {}", WebSocketEventSubscriberServer.class.getCanonicalName(), port,
+                        eventString);
         eventsReceivedCount++;
     }
 
@@ -73,7 +76,7 @@ public class WebSocketEventSubscriberServer implements WsStringMessageListener {
      */
     public void shutdown() {
         server.stop();
-        System.out.println(WebSocketEventSubscriberServer.class.getCanonicalName() + ": stopped");
+        LOGGER.debug("{} : stopped", WebSocketEventSubscriberServer.class.getCanonicalName());
     }
 
     /**
@@ -84,7 +87,7 @@ public class WebSocketEventSubscriberServer implements WsStringMessageListener {
      */
     public static void main(final String[] args) throws MessagingException {
         if (args.length != 1) {
-            System.err.println("usage WebSocketEventSubscriberClient port");
+            LOGGER.error("usage WebSocketEventSubscriberClient port");
             return;
         }
 
@@ -92,7 +95,7 @@ public class WebSocketEventSubscriberServer implements WsStringMessageListener {
         try {
             port = Integer.parseInt(args[0]);
         } catch (final Exception e) {
-            System.err.println("usage WebSocketEventSubscriberClient port");
+            LOGGER.error("usage WebSocketEventSubscriberClient port");
             e.printStackTrace();
             return;
         }
diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/engine/ApexServiceTest.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/engine/ApexServiceTest.java
index 34893ca5c..2377cfb91 100644
--- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/engine/ApexServiceTest.java
+++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/engine/ApexServiceTest.java
@@ -5,15 +5,15 @@
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *      http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
- * 
+ *
  * SPDX-License-Identifier: Apache-2.0
  * ============LICENSE_END=========================================================
  */
@@ -103,7 +103,6 @@ public class ApexServiceTest {
         parameters.getEngineParameters().getExecutorParameterMap().put("MVEL", new MvelExecutorParameters());
         service = EngineServiceImpl.create(parameters);
 
-
         LOGGER.debug("Running TestApexEngine. . .");
 
         apexPolicyModel = new SampleDomainModelFactory().getSamplePolicyModel("JAVASCRIPT");
@@ -127,12 +126,12 @@ public class ApexServiceTest {
         ParameterService.register(new LockManagerParameters());
         ParameterService.register(new PersistorParameters());
         ParameterService.register(new EngineServiceParameters());
-        
+
         EngineParameters engineParameters = new EngineParameters();
         engineParameters.getExecutorParameterMap().put("JAVASCRIPT", new JavascriptExecutorParameters());
         ParameterService.register(engineParameters);
     }
-    
+
     /**
      * Clear down parameters.
      */
@@ -146,7 +145,7 @@ public class ApexServiceTest {
         ParameterService.deregister(ContextParameterConstants.MAIN_GROUP_NAME);
         ParameterService.deregister(ContextParameterConstants.SCHEMA_GROUP_NAME);
     }
-    
+
     /**
      * Update the engine then test the engine with 2 sample events.
      *
@@ -158,7 +157,7 @@ public class ApexServiceTest {
 
         final long starttime = System.currentTimeMillis();
         for (final AxArtifactKey engineKey : service.getEngineKeys()) {
-            LOGGER.info("{}", service.getStatus(engineKey));
+            LOGGER.debug("{}", service.getStatus(engineKey));
         }
         while (!service.isStarted() && System.currentTimeMillis() - starttime < MAX_START_WAIT) {
             ThreadUtilities.sleep(200);
@@ -177,14 +176,14 @@ public class ApexServiceTest {
         eventDataMap.put("TestTimestamp", testStartTime.getTime());
         eventDataMap.put("TestTemperature", 34.5445667);
 
-        final ApexEvent event =
-                new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+        final ApexEvent event = new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+                        "test", "apex");
         event.setExecutionId(System.nanoTime());
         event.putAll(eventDataMap);
         engineServiceEventInterface.sendEvent(event);
 
-        final ApexEvent event2 =
-                new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+        final ApexEvent event2 = new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+                        "test", "apex");
         event2.setExecutionId(System.nanoTime());
         event2.putAll(eventDataMap);
         engineServiceEventInterface.sendEvent(event2);
@@ -198,7 +197,6 @@ public class ApexServiceTest {
         assertEquals(2, actionEventsReceived);
         actionEventsReceived = 0;
 
-
         // Stop all engines on this engine service
         final long stoptime = System.currentTimeMillis();
         service.stop();
@@ -221,7 +219,7 @@ public class ApexServiceTest {
 
         final long starttime = System.currentTimeMillis();
         for (final AxArtifactKey engineKey : service.getEngineKeys()) {
-            LOGGER.info("{}", service.getStatus(engineKey));
+            LOGGER.debug("{}", service.getStatus(engineKey));
         }
         while (!service.isStarted() && System.currentTimeMillis() - starttime < MAX_START_WAIT) {
             ThreadUtilities.sleep(200);
@@ -238,8 +236,8 @@ public class ApexServiceTest {
         eventDataMap.put("TestTimestamp", testStartTime.getTime());
         eventDataMap.put("TestTemperature", 34.5445667);
 
-        final ApexEvent event1 =
-                new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+        final ApexEvent event1 = new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+                        "test", "apex");
         event1.putAll(eventDataMap);
         event1.setExecutionId(System.nanoTime());
 
@@ -260,8 +258,8 @@ public class ApexServiceTest {
             ThreadUtilities.sleep(100);
         }
 
-        final ApexEvent event2 =
-                new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+        final ApexEvent event2 = new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+                        "test", "apex");
         event2.setExecutionId(System.nanoTime());
         event2.putAll(eventDataMap);
 
@@ -309,7 +307,7 @@ public class ApexServiceTest {
 
         final long starttime = System.currentTimeMillis();
         for (final AxArtifactKey engineKey : service.getEngineKeys()) {
-            LOGGER.info("{}", service.getStatus(engineKey));
+            LOGGER.debug("{}", service.getStatus(engineKey));
         }
         while (!service.isStarted() && System.currentTimeMillis() - starttime < MAX_START_WAIT) {
             ThreadUtilities.sleep(200);
@@ -328,14 +326,14 @@ public class ApexServiceTest {
         eventDataMap.put("TestTimestamp", testStartTime.getTime());
         eventDataMap.put("TestTemperature", 34.5445667);
 
-        final ApexEvent event =
-                new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+        final ApexEvent event = new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+                        "test", "apex");
         event.setExecutionId(System.nanoTime());
         event.putAll(eventDataMap);
         engineServiceEventInterface.sendEvent(event);
 
-        final ApexEvent event2 =
-                new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+        final ApexEvent event2 = new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+                        "test", "apex");
         event2.setExecutionId(System.nanoTime());
         event2.putAll(eventDataMap);
         engineServiceEventInterface.sendEvent(event2);
@@ -371,7 +369,7 @@ public class ApexServiceTest {
 
         final long starttime = System.currentTimeMillis();
         for (final AxArtifactKey engineKey : service.getEngineKeys()) {
-            LOGGER.info("{}", service.getStatus(engineKey));
+            LOGGER.debug("{}", service.getStatus(engineKey));
         }
         while (!service.isStarted() && System.currentTimeMillis() - starttime < MAX_START_WAIT) {
             ThreadUtilities.sleep(200);
@@ -388,8 +386,8 @@ public class ApexServiceTest {
         eventDataMap.put("TestTimestamp", testStartTime.getTime());
         eventDataMap.put("TestTemperature", 34.5445667);
 
-        final ApexEvent event1 =
-                new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+        final ApexEvent event1 = new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+                        "test", "apex");
         event1.putAll(eventDataMap);
 
         final ApexEventListener myEventListener1 = new ApexEventListener() {
@@ -409,8 +407,8 @@ public class ApexServiceTest {
             ThreadUtilities.sleep(100);
         }
 
-        final ApexEvent event2 =
-                new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+        final ApexEvent event2 = new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+                        "test", "apex");
         event2.putAll(eventDataMap);
 
         final ApexEventListener myEventListener2 = new ApexEventListener() {
@@ -468,10 +466,10 @@ public class ApexServiceTest {
     }
 
     /**
-     * The listener interface for receiving test events. The class that is interested in processing
-     * a test event implements this interface, and the object created with that class is registered
-     * with a component using the component's <code>addTestListener</code> method. When the test
-     * event occurs, that object's appropriate method is invoked.
+     * The listener interface for receiving test events. The class that is interested in processing a test event
+     * implements this interface, and the object created with that class is registered with a component using the
+     * component's <code>addTestListener</code> method. When the test event occurs, that object's appropriate method is
+     * invoked.
      *
      * @see TestEvent
      */
@@ -489,7 +487,7 @@ public class ApexServiceTest {
             final Date testStartTime = new Date((Long) event.get("TestTimestamp"));
             final Date testEndTime = new Date();
 
-            LOGGER.info("policy execution time: " + (testEndTime.getTime() - testStartTime.getTime()) + "ms");
+            LOGGER.debug("policy execution time: " + (testEndTime.getTime() - testStartTime.getTime()) + "ms");
         }
 
         /**
@@ -504,13 +502,13 @@ public class ApexServiceTest {
             assertTrue(result.get("TestMatchCase").equals(new Byte((byte) 123)));
             assertTrue(result.get("TestTemperature").equals(34.5445667));
             assertTrue(((byte) result.get("TestMatchCaseSelected")) >= 0
-                    && ((byte) result.get("TestMatchCaseSelected") <= 3));
+                            && ((byte) result.get("TestMatchCaseSelected") <= 3));
             assertTrue(((byte) result.get("TestEstablishCaseSelected")) >= 0
-                    && ((byte) result.get("TestEstablishCaseSelected") <= 3));
+                            && ((byte) result.get("TestEstablishCaseSelected") <= 3));
             assertTrue(((byte) result.get("TestDecideCaseSelected")) >= 0
-                    && ((byte) result.get("TestDecideCaseSelected") <= 3));
-            assertTrue(
-                    ((byte) result.get("TestActCaseSelected")) >= 0 && ((byte) result.get("TestActCaseSelected") <= 3));
+                            && ((byte) result.get("TestDecideCaseSelected") <= 3));
+            assertTrue(((byte) result.get("TestActCaseSelected")) >= 0
+                            && ((byte) result.get("TestActCaseSelected") <= 3));
         }
     }