src/main/java/com/gitblit/fanout/FanoutNioService.java
@@ -142,7 +142,7 @@ Set<SelectionKey> keys = selector.selectedKeys(); Iterator<SelectionKey> keyItr = keys.iterator(); while (keyItr.hasNext()) { SelectionKey key = (SelectionKey) keyItr.next(); SelectionKey key = keyItr.next(); if (key.isAcceptable()) { // new fanout client connection ServerSocketChannel sch = (ServerSocketChannel) key.channel(); @@ -222,6 +222,7 @@ } } @Override protected void broadcast(Collection<FanoutServiceConnection> connections, String channel, String message) { super.broadcast(connections, channel, message);