From b696df52eca30ef723df4cbd1de9adcde5d7e3a9 Mon Sep 17 00:00:00 2001 From: Dmitry Golovin Date: Fri, 26 Sep 2014 15:33:31 +0400 Subject: [PATCH] #162 implement missed method getRoomBroadcastOperation --- .../java/com/corundumstudio/socketio/SocketIONamespace.java | 2 ++ .../com/corundumstudio/socketio/namespace/Namespace.java | 5 +++++ 2 files changed, 7 insertions(+) diff --git a/src/main/java/com/corundumstudio/socketio/SocketIONamespace.java b/src/main/java/com/corundumstudio/socketio/SocketIONamespace.java index a8a60a1..13843db 100644 --- a/src/main/java/com/corundumstudio/socketio/SocketIONamespace.java +++ b/src/main/java/com/corundumstudio/socketio/SocketIONamespace.java @@ -28,6 +28,8 @@ public interface SocketIONamespace extends ClientListeners { BroadcastOperations getBroadcastOperations(); + BroadcastOperations getRoomOperations(String room); + /** * Get all clients connected to namespace * diff --git a/src/main/java/com/corundumstudio/socketio/namespace/Namespace.java b/src/main/java/com/corundumstudio/socketio/namespace/Namespace.java index 3f763e4..bfb7eb6 100644 --- a/src/main/java/com/corundumstudio/socketio/namespace/Namespace.java +++ b/src/main/java/com/corundumstudio/socketio/namespace/Namespace.java @@ -205,6 +205,11 @@ public class Namespace implements SocketIONamespace { return new BroadcastOperations(allClients.values(), storeFactory); } + @Override + public BroadcastOperations getRoomOperations(String room) { + return new BroadcastOperations(getRoomClients(room), storeFactory); + } + @Override public int hashCode() { final int prime = 31;