|
@@ -153,6 +153,9 @@ public class DefaultServer implements Server
|
|
|
|
|
|
|
|
public void broadcast( Filter<? super HostedConnection> filter, Message message )
|
|
public void broadcast( Filter<? super HostedConnection> filter, Message message )
|
|
|
{
|
|
{
|
|
|
|
|
+ if( connections.isEmpty() )
|
|
|
|
|
+ return;
|
|
|
|
|
+
|
|
|
ByteBuffer buffer = MessageProtocol.messageToBuffer(message, null);
|
|
ByteBuffer buffer = MessageProtocol.messageToBuffer(message, null);
|
|
|
|
|
|
|
|
FilterAdapter adapter = filter == null ? null : new FilterAdapter(filter);
|
|
FilterAdapter adapter = filter == null ? null : new FilterAdapter(filter);
|
|
@@ -172,6 +175,11 @@ public class DefaultServer implements Server
|
|
|
return connections.get(id);
|
|
return connections.get(id);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ public boolean hasConnections()
|
|
|
|
|
+ {
|
|
|
|
|
+ return !connections.isEmpty();
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
public Collection<HostedConnection> getConnections()
|
|
public Collection<HostedConnection> getConnections()
|
|
|
{
|
|
{
|
|
|
return Collections.unmodifiableCollection((Collection<HostedConnection>)connections.values());
|
|
return Collections.unmodifiableCollection((Collection<HostedConnection>)connections.values());
|