diff options
| author | jason | 2015-12-04 17:15:05 -0700 |
|---|---|---|
| committer | jason | 2015-12-04 17:15:05 -0700 |
| commit | e59910fd96b38ec930128220fbdd67af4586e0d8 (patch) | |
| tree | 32e5de7fe64794b142de6f02b67d1ea2571d781d /docs/protocol.rst | |
| parent | fff3c0c9337fefac954614855c11087626ae9677 (diff) | |
| download | eventmq-e59910fd96b38ec930128220fbdd67af4586e0d8.tar.gz eventmq-e59910fd96b38ec930128220fbdd67af4586e0d8.zip | |
fix to logging, send multiple messages to workers
- JobManager now replies with READY when it's 'finished' with the job to
requeue the worker in the broker.
- some improvements to logging that prevents duplicate messages
Diffstat (limited to 'docs/protocol.rst')
| -rw-r--r-- | docs/protocol.rst | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/docs/protocol.rst b/docs/protocol.rst index 86491dc..e468b06 100644 --- a/docs/protocol.rst +++ b/docs/protocol.rst | |||
| @@ -5,7 +5,7 @@ EventMQ Protocol Specification | |||
| 5 | 5 | ||
| 6 | Goals | 6 | Goals |
| 7 | ===== | 7 | ===== |
| 8 | The EventMQ Protocol (eMQP) defines a reliable service-oriented request-reply and pub-sub dialog between a set of clients, a broker, and a set of workers. This goal is to | 8 | The EventMQ Protocol (eMQP) defines a reliable service-oriented request-reply and pub-sub dialog between a set of clients, a broker, and a set of workers. This goal is to |
| 9 | 9 | ||
| 10 | The goals are to: | 10 | The goals are to: |
| 11 | 11 | ||
| @@ -13,7 +13,7 @@ The goals are to: | |||
| 13 | * Allow requests to be routed to workers by an abstracted service name. | 13 | * Allow requests to be routed to workers by an abstracted service name. |
| 14 | * Detect disconnected peers through heartbeating. | 14 | * Detect disconnected peers through heartbeating. |
| 15 | * Allow for message tracing and debugging. | 15 | * Allow for message tracing and debugging. |
| 16 | 16 | ||
| 17 | 17 | ||
| 18 | License | 18 | License |
| 19 | ======= | 19 | ======= |
| @@ -69,7 +69,7 @@ FRAME Value Description | |||
| 69 | ====== ============== =========== | 69 | ====== ============== =========== |
| 70 | 0 _EMPTY_ leave empty | 70 | 0 _EMPTY_ leave empty |
| 71 | 1 eMQP/1.0 Protocol version | 71 | 1 eMQP/1.0 Protocol version |
| 72 | 2 READY command | 72 | 2 REQUEST command |
| 73 | 3 _MSGID_ A unique id for the msg | 73 | 3 _MSGID_ A unique id for the msg |
| 74 | 4 _QUEUE_NAME_ the name of the queue the worker belongs to | 74 | 4 _QUEUE_NAME_ the name of the queue the worker belongs to |
| 75 | 5 _HEADERS_ dictionary of headers. can be an empty set | 75 | 5 _HEADERS_ dictionary of headers. can be an empty set |