Finish Integration With Relay

Added a system called the Timeline which allows work to be
set to run at specific points in time. This allows work to
be queued.

To allow the relay server data to merge in with the server,
a work item is set to run every minute. When it finishs, it
sets itself to run again in a minute.

When data needs to be sent to the relay, a work item is added
to the timeline so that the current connection can be closed
before sending data to the relay.

The timeline allowed for the Hub to be removed as work items
to handle connections could be added to the timeline.

Closes #4.

Author: vaage

src/codeu/chat/server/Server.java

@@ -40,7 +40,9 @@
 
 public final class Server {
 
-  private final static Logger.Log LOG = Logger.newLog(Server.class);
+  private static final Logger.Log LOG = Logger.newLog(Server.class);
+
+  private static final int RELAY_REFRESH_MS = 5000;  // 5 seconds
 
   private final Timeline timeline = new Timeline();
 
@@ -80,8 +82,7 @@ public void run() {
 
         }
 
-        // Do this again in 5 seconds
-        timeline.scheduleIn(5000, this);
+        timeline.scheduleIn(RELAY_REFRESH_MS, this);
       }
     });
   }

src/codeu/chat/util/Timeline.java

@@ -161,7 +161,7 @@ public void scheduleAt(long timeMs, Runnable callback) {
   public void stop() {
     running = false;
 
-    // Interrupt does not force a thread to exit. It signal's the
+    // Interrupt does not force a thread to exit. It signals the
     // thead that it is time to stop execution. As the threads may
     // be sleeping, this will force them awake.
     executor.interrupt();
@@ -189,7 +189,7 @@ private static void forceJoin(Thread thread) {
 
   private static <T> void forceAdd(BlockingQueue<T> queue, T value) {
     while (!queue.offer(value)) {
-      // try again...
+      LOG.warning("Failed to add to queue, trying again...");
     }
   }
 }