summaryrefslogtreecommitdiffstats
path: root/core
diff options
context:
space:
mode:
Diffstat (limited to 'core')
-rw-r--r--core/core-infrastructure/src/main/java/org/onap/policy/apex/core/infrastructure/messaging/impl/ws/server/MessageServerImpl.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/core/core-infrastructure/src/main/java/org/onap/policy/apex/core/infrastructure/messaging/impl/ws/server/MessageServerImpl.java b/core/core-infrastructure/src/main/java/org/onap/policy/apex/core/infrastructure/messaging/impl/ws/server/MessageServerImpl.java
index ee6e1a329..389d04dcc 100644
--- a/core/core-infrastructure/src/main/java/org/onap/policy/apex/core/infrastructure/messaging/impl/ws/server/MessageServerImpl.java
+++ b/core/core-infrastructure/src/main/java/org/onap/policy/apex/core/infrastructure/messaging/impl/ws/server/MessageServerImpl.java
@@ -91,7 +91,7 @@ public class MessageServerImpl<MESSAGE> extends InternalMessageBusServer<MESSAGE
// Stop the web socket server
try {
// Close all connections on this web socket server
- for (final WebSocket connection : connections()) {
+ for (final WebSocket connection : getConnections()) {
connection.closeConnection(0, "");
}
stop();
@@ -128,7 +128,7 @@ public class MessageServerImpl<MESSAGE> extends InternalMessageBusServer<MESSAGE
@Override
public void send(final MessageHolder<MESSAGE> message) {
// Send the incoming message to all clients connected to this web socket
- final Collection<WebSocket> connections = connections();
+ final Collection<WebSocket> connections = getConnections();
for (final WebSocket webSocket : connections) {
webSocket.send(MessagingUtils.serializeObject(message));
}
@@ -142,7 +142,7 @@ public class MessageServerImpl<MESSAGE> extends InternalMessageBusServer<MESSAGE
*/
@Override
public void send(final String messageString) {
- final Collection<WebSocket> connections = connections();
+ final Collection<WebSocket> connections = getConnections();
for (final WebSocket webSocket : connections) {
webSocket.send(messageString);
}