James Moger
2013-09-30 699e71e76b15081baf746c6ce9c9144f7e5f1ff9
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);