Many changes

- organizes some code
- Router sends acknowledgement after jobmanager INFORMs

7 files changed, 61 insertions, 2 deletions

diff --git a/docs/api.rst b/docs/api.rst
index b0ecf4e..b3cdc83 100644
--- a/docs/api.rst
+++ b/docs/api.rst
@@ -5,9 +5,10 @@ API Documentation
 .. toctree::
    :maxdepth: 2
 
+   exceptions
    jobmanager
+   poller
    receiver
    router
    sender
    utils
-   exceptions
diff --git a/docs/contributing.rst b/docs/contributing.rst
index c0a03fb..2489abb 100644
--- a/docs/contributing.rst
+++ b/docs/contributing.rst
@@ -2,7 +2,13 @@
 Contributing to EventMQ
 #######################
 
+A few tips when working on the code
+
+ * Use relative imports. If you use absolute imports then when you `import eventmq.exceptions` it's possible that you receive in return a different version of eventmq. exceptions installed somewhere else on the system.
+
 .. toctree::
    :maxdepth: 1
    
    protocol
+   Source Code <https://github.com/enderlabs/eventmq>
+   Issues <https://github.com/enderlabs/eventmq/issues>
diff --git a/docs/exceptions.rst b/docs/exceptions.rst
new file mode 100644
index 0000000..04f9c5a
--- /dev/null
+++ b/docs/exceptions.rst
@@ -0,0 +1,2 @@
+.. automodule:: eventmq.exceptions
+   :members:
diff --git a/docs/poller.rst b/docs/poller.rst
new file mode 100644
index 0000000..1aab472
--- /dev/null
+++ b/docs/poller.rst
@@ -0,0 +1,3 @@
+.. automodule:: eventmq.poller
+   :members:
+   :special-members:
diff --git a/docs/protocol.rst b/docs/protocol.rst
index d9bd9e1..c32501c 100644
--- a/docs/protocol.rst
+++ b/docs/protocol.rst
@@ -46,9 +46,22 @@ From the 0MQ manual[[2](http://api.zeromq.org/master:zmq-socket)]
 
 This extra frame is not shown in the specifications below.
 
+Global Frames
+-------------
+An **ACK** command consists of a 4-frame multipart message, formatted as follows.
+
+====== ============== ===========
+FRAME  Value          Description
+====== ============== ===========
+0      _EMPTY_        leave empty
+1      eMQP/1.0       Protocol version
+2      ACK            command
+3      _MSGID_        A unique id for the msg
+====== ============== ===========
+
 eMQP / Client
 -------------
-A **REQUEST** command consists of 7-frame multipart message, formatted as follows. 
+A **REQUEST** command consists of a 7-frame multipart message, formatted as follows.
 
 ====== ============== ===========
 FRAME  Value          Description
@@ -62,6 +75,20 @@ FRAME  Value          Description
 6      _MSG_          The message to send
 ====== ============== ===========
 
+A **PUBLISH** command consists of a 7-frame multipart messag, formatted as follows.
+
+====== ============== ===========
+FRAME  Value          Description
+====== ============== ===========
+0      _EMPTY_        leave empty
+1      eMQP/1.0       Protocol version
+2      PUBLISH        command
+3      _MSGID_        A unique id for the msg
+4      _TOPIC_NAME_   the name of the queue the worker belongs to
+5      _HEADERS_      dictionary of headers. can be an empty set
+6      _MSG_          The message to send
+====== ============== ===========
+
 eMQP / Worker
 -------------
 An **INFORM** command consists of a 5-frame multipart message, formatted as follows.
@@ -128,3 +155,17 @@ Heartbeating
  * Both worker and broker MUST send heartbeats at regular and agreed-upon intervals.
  * If the worker detects that the broker disconnected it SHOULD restart the conversation.
  * If the broker detects that a worker has disconnected it should stop sending it a message of any type.
+
+Request Headers
+---------------
+Headers MUST be 0 to many comma seperated values inserted into the header field. If there are no headers requried, send an empty string MUST be sent where headers are required.
+
+Below is a table which defines and describes the headers.
+
+=============== ======= ======= ======= ===========
+Header          REQUEST PUBLISH Default Description
+=============== ======= ======= ======= ===========
+reply-requested X               False     Once the job is finished, send a reply back with information from the job. If there is no information reply with a True value.
+retry-count:#   X               0       Retry a failed job this many times before accepting defeat.
+guarantee       X               False     Ensure the job completes by letting someone else worry about a success reply.
+=============== ======= ======= ======= ===========
diff --git a/docs/utils/classes.rst b/docs/utils/classes.rst
new file mode 100644
index 0000000..ab48e06
--- /dev/null
+++ b/docs/utils/classes.rst
@@ -0,0 +1,3 @@
+.. automodule:: eventmq.utils.classes
+   :members:
+   :special-members:
diff --git a/docs/utils/messages.rst b/docs/utils/messages.rst
new file mode 100644
index 0000000..e49897c
--- /dev/null
+++ b/docs/utils/messages.rst
@@ -0,0 +1,3 @@
+.. automodule:: eventmq.utils.messages
+   :members:
+   :special-members: