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;