diff options
| author | jason | 2015-11-20 11:42:18 -0700 |
|---|---|---|
| committer | jason | 2015-11-20 11:42:18 -0700 |
| commit | d4d1fe943380d087de3f0a54965d8dbb647b629c (patch) | |
| tree | e3fa19815b5ee09fb09da0d38c7c156dbd8ea633 /_sources/protocol.txt | |
| parent | c972be300c5d182ad2a229cabb3150b365acad6b (diff) | |
| download | eventmq-d4d1fe943380d087de3f0a54965d8dbb647b629c.tar.gz eventmq-d4d1fe943380d087de3f0a54965d8dbb647b629c.zip | |
updates
Diffstat (limited to '_sources/protocol.txt')
| -rw-r--r-- | _sources/protocol.txt | 30 |
1 files changed, 29 insertions, 1 deletions
diff --git a/_sources/protocol.txt b/_sources/protocol.txt index d9bd9e1..e4d5b7f 100644 --- a/_sources/protocol.txt +++ b/_sources/protocol.txt | |||
| @@ -48,7 +48,7 @@ This extra frame is not shown in the specifications below. | |||
| 48 | 48 | ||
| 49 | eMQP / Client | 49 | eMQP / Client |
| 50 | ------------- | 50 | ------------- |
| 51 | A **REQUEST** command consists of 7-frame multipart message, formatted as follows. | 51 | A **REQUEST** command consists of a 7-frame multipart message, formatted as follows. |
| 52 | 52 | ||
| 53 | ====== ============== =========== | 53 | ====== ============== =========== |
| 54 | FRAME Value Description | 54 | FRAME Value Description |
| @@ -62,6 +62,20 @@ FRAME Value Description | |||
| 62 | 6 _MSG_ The message to send | 62 | 6 _MSG_ The message to send |
| 63 | ====== ============== =========== | 63 | ====== ============== =========== |
| 64 | 64 | ||
| 65 | A **PUBLISH** command consists of a 7-frame multipart messag, formatted as follows. | ||
| 66 | |||
| 67 | ====== ============== =========== | ||
| 68 | FRAME Value Description | ||
| 69 | ====== ============== =========== | ||
| 70 | 0 _EMPTY_ leave empty | ||
| 71 | 1 eMQP/1.0 Protocol version | ||
| 72 | 2 PUBLISH command | ||
| 73 | 3 _MSGID_ A unique id for the msg | ||
| 74 | 4 _TOPIC_NAME_ the name of the queue the worker belongs to | ||
| 75 | 5 _HEADERS_ dictionary of headers. can be an empty set | ||
| 76 | 6 _MSG_ The message to send | ||
| 77 | ====== ============== =========== | ||
| 78 | |||
| 65 | eMQP / Worker | 79 | eMQP / Worker |
| 66 | ------------- | 80 | ------------- |
| 67 | An **INFORM** command consists of a 5-frame multipart message, formatted as follows. | 81 | An **INFORM** command consists of a 5-frame multipart message, formatted as follows. |
| @@ -128,3 +142,17 @@ Heartbeating | |||
| 128 | * Both worker and broker MUST send heartbeats at regular and agreed-upon intervals. | 142 | * Both worker and broker MUST send heartbeats at regular and agreed-upon intervals. |
| 129 | * If the worker detects that the broker disconnected it SHOULD restart the conversation. | 143 | * If the worker detects that the broker disconnected it SHOULD restart the conversation. |
| 130 | * If the broker detects that a worker has disconnected it should stop sending it a message of any type. | 144 | * If the broker detects that a worker has disconnected it should stop sending it a message of any type. |
| 145 | |||
| 146 | Request Headers | ||
| 147 | --------------- | ||
| 148 | 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. | ||
| 149 | |||
| 150 | Below is a table which defines and describes the headers. | ||
| 151 | |||
| 152 | =============== ======= ======= ======= =========== | ||
| 153 | Header REQUEST PUBLISH Default Description | ||
| 154 | =============== ======= ======= ======= =========== | ||
| 155 | 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. | ||
| 156 | retry-count:# X 0 Retry a failed job this many times before accepting defeat. | ||
| 157 | guarentee X False Ensure the job completes by letting someone else worry about a success reply. | ||
| 158 | =============== ======= ======= ======= =========== | ||