Merge branch 'nextgen' into nextgen_listener

source/tristanable/exceptions.d

@@ -3,13 +3,32 @@
  */
 module tristanable.exceptions;
 
+/** 
+ * The type of sub-error of the `TristanableException`
+ */
 public enum ErrorType
 {
+    /**
+     * If the requested queue could not be found
+     */
     QUEUE_NOT_FOUND,
+
+    /**
+     * If the queue wanting to be registered has already
+     * been registered under the same tag
+     */
     QUEUE_ALREADY_EXISTS,
+
+    /** 
+     * If no default queue is configured
+     */
     NO_DEFAULT_QUEUE
 }
 
+/** 
+ * Any sort of error that occurs during runtime of the tristanable
+ * engine
+ */
 public class TristanableException : Exception
 {
     private ErrorType err;

source/tristanable/manager/watcher.d

@@ -125,7 +125,11 @@ public class Watcher : Thread
     }
 }
 
-
+/** 
+ * Set up a server which will send some tagged messages to us (the client),
+ * where we have setup a `Manager` to watch the queues with tags `42` and `69`,
+ * we then dequeue some messages from both queus. Finally, we shut down the manager.
+ */
 unittest
 {
     import std.socket;