diff options
Diffstat (limited to 'testsuites/integration/integration-uservice-test/src/test')
4 files changed, 20 insertions, 20 deletions
diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventProducerClient.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventProducerClient.java index dc186a1e8..bda312c42 100644 --- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventProducerClient.java +++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventProducerClient.java @@ -22,11 +22,11 @@ package org.onap.policy.apex.apps.uservice.test.adapt.websocket; import org.onap.policy.apex.apps.uservice.test.adapt.events.EventGenerator; 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.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageClient; +import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageListener; import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities; -public class WebSocketEventProducerClient implements WSStringMessageListener { +public class WebSocketEventProducerClient implements WsStringMessageListener { private final String host; private final int port; private final int eventCount; @@ -34,7 +34,7 @@ public class WebSocketEventProducerClient implements WSStringMessageListener { private final long eventInterval; private long eventsSentCount = 0; - WSStringMessageClient client; + WsStringMessageClient client; public WebSocketEventProducerClient(final String host, final int port, final int eventCount, final boolean xmlEvents, final long eventInterval) throws MessagingException { @@ -44,7 +44,7 @@ public class WebSocketEventProducerClient implements WSStringMessageListener { this.xmlEvents = xmlEvents; this.eventInterval = eventInterval; - client = new WSStringMessageClient(host, port); + client = new WsStringMessageClient(host, port); client.start(this); System.out.println(WebSocketEventProducerClient.class.getCanonicalName() + ": host " + host + ", port " + port diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventProducerServer.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventProducerServer.java index 32b463d6f..a36c4d61e 100644 --- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventProducerServer.java +++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventProducerServer.java @@ -22,18 +22,18 @@ package org.onap.policy.apex.apps.uservice.test.adapt.websocket; import org.onap.policy.apex.apps.uservice.test.adapt.events.EventGenerator; 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.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageListener; +import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageServer; import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities; -public class WebSocketEventProducerServer implements WSStringMessageListener { +public class WebSocketEventProducerServer implements WsStringMessageListener { private final int port; private final int eventCount; private final boolean xmlEvents; private final long eventInterval; private long eventsSentCount = 0; - WSStringMessageServer server; + WsStringMessageServer server; public WebSocketEventProducerServer(final int port, final int eventCount, final boolean xmlEvents, final long eventInterval) throws MessagingException { @@ -42,7 +42,7 @@ public class WebSocketEventProducerServer implements WSStringMessageListener { this.xmlEvents = xmlEvents; this.eventInterval = eventInterval; - server = new WSStringMessageServer(port); + server = new WsStringMessageServer(port); server.start(this); System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": port " + port + ", event count " diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventSubscriberClient.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventSubscriberClient.java index 639d7ae77..48ca9c884 100644 --- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventSubscriberClient.java +++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventSubscriberClient.java @@ -21,19 +21,19 @@ package org.onap.policy.apex.apps.uservice.test.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.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageClient; +import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageListener; -public class WebSocketEventSubscriberClient implements WSStringMessageListener { +public class WebSocketEventSubscriberClient implements WsStringMessageListener { private final int port; private long eventsReceivedCount = 0; - private final WSStringMessageClient client; + private final WsStringMessageClient client; public WebSocketEventSubscriberClient(final String host, final int port) throws MessagingException { this.port = port; - client = new WSStringMessageClient(host, port); + client = new WsStringMessageClient(host, port); client.start(this); } diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventSubscriberServer.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventSubscriberServer.java index bfa543774..83e324b9c 100644 --- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventSubscriberServer.java +++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/apps/uservice/test/adapt/websocket/WebSocketEventSubscriberServer.java @@ -21,19 +21,19 @@ package org.onap.policy.apex.apps.uservice.test.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.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageListener; +import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageServer; -public class WebSocketEventSubscriberServer implements WSStringMessageListener { +public class WebSocketEventSubscriberServer implements WsStringMessageListener { private final int port; private long eventsReceivedCount = 0; - private final WSStringMessageServer server; + private final WsStringMessageServer server; public WebSocketEventSubscriberServer(final int port) throws MessagingException { this.port = port; - server = new WSStringMessageServer(port); + server = new WsStringMessageServer(port); server.start(this); System.out.println( |