diff options
Diffstat (limited to '_sources/protocol.txt')
| -rw-r--r-- | _sources/protocol.txt | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/_sources/protocol.txt b/_sources/protocol.txt index 4c2aff0..c341403 100644 --- a/_sources/protocol.txt +++ b/_sources/protocol.txt | |||
| @@ -71,7 +71,7 @@ FRAME Value Description | |||
| 71 | 1 eMQP/1.0 Protocol version | 71 | 1 eMQP/1.0 Protocol version |
| 72 | 2 REQUEST 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 request should be sent to |
| 75 | 5 _HEADERS_ dictionary of headers. can be an empty set | 75 | 5 _HEADERS_ dictionary of headers. can be an empty set |
| 76 | 6 _MSG_ The message to send | 76 | 6 _MSG_ The message to send |
| 77 | ====== ============== =========== | 77 | ====== ============== =========== |
| @@ -85,7 +85,7 @@ FRAME Value Description | |||
| 85 | 1 eMQP/1.0 Protocol version | 85 | 1 eMQP/1.0 Protocol version |
| 86 | 2 PUBLISH command | 86 | 2 PUBLISH command |
| 87 | 3 _MSGID_ A unique id for the msg | 87 | 3 _MSGID_ A unique id for the msg |
| 88 | 4 _TOPIC_NAME_ the name of the queue the worker belongs to | 88 | 4 _TOPIC_NAME_ the name of the topic this message should be published across |
| 89 | 5 _HEADERS_ csv list of headers | 89 | 5 _HEADERS_ csv list of headers |
| 90 | 6 _MSG_ The message to send | 90 | 6 _MSG_ The message to send |
| 91 | ====== ============== =========== | 91 | ====== ============== =========== |
| @@ -99,7 +99,7 @@ FRAME Value Description | |||
| 99 | 1 eMQP/1.0 Protocol version | 99 | 1 eMQP/1.0 Protocol version |
| 100 | 2 SCHEDULE command | 100 | 2 SCHEDULE command |
| 101 | 3 _MSGID_ A unique id for the msg | 101 | 3 _MSGID_ A unique id for the msg |
| 102 | 4 _TOPIC_NAME_ name of queue that the job should run in | 102 | 4 _QUEUE_NAME_ name of queue that the job should run in |
| 103 | 5 _HEADERS_ csv list of headers for this message | 103 | 5 _HEADERS_ csv list of headers for this message |
| 104 | 6 _MSG_ The message to send | 104 | 6 _MSG_ The message to send |
| 105 | ====== ============== =========== | 105 | ====== ============== =========== |
| @@ -113,7 +113,7 @@ FRAME Value Description | |||
| 113 | 1 eMQP/1.0 Protocol version | 113 | 1 eMQP/1.0 Protocol version |
| 114 | 2 UNSCHEDULE command | 114 | 2 UNSCHEDULE command |
| 115 | 3 _MSGID_ A unique id for the msg | 115 | 3 _MSGID_ A unique id for the msg |
| 116 | 4 _TOPIC_NAME_ ignored for this command, broadcasted to all queues | 116 | 4 _QUEUE_NAME_ ignored for this command, broadcasted to all queues |
| 117 | 5 _HEADERS_ csv list of headers for this message | 117 | 5 _HEADERS_ csv list of headers for this message |
| 118 | 6 _MSG_ The message to send | 118 | 6 _MSG_ The message to send |
| 119 | ====== ============== =========== | 119 | ====== ============== =========== |
| @@ -129,7 +129,7 @@ FRAME Value Description | |||
| 129 | 1 eMQP/1.0 Protocol version | 129 | 1 eMQP/1.0 Protocol version |
| 130 | 2 INFORM command | 130 | 2 INFORM command |
| 131 | 3 _MSGID_ A unique id for the msg | 131 | 3 _MSGID_ A unique id for the msg |
| 132 | 4 _QUEUE_NAME_ csv seperated names of queue the worker belongs to | 132 | 4 Queues. Unused for scheduler |
| 133 | 5 scheduler type of peer connecting | 133 | 5 scheduler type of peer connecting |
| 134 | ====== ============== =========== | 134 | ====== ============== =========== |
| 135 | 135 | ||
| @@ -144,7 +144,7 @@ FRAME Value Description | |||
| 144 | 1 eMQP/1.0 Protocol version | 144 | 1 eMQP/1.0 Protocol version |
| 145 | 2 INFORM command | 145 | 2 INFORM command |
| 146 | 3 _MSGID_ A unique id for the msg | 146 | 3 _MSGID_ A unique id for the msg |
| 147 | 4 _QUEUE_NAME_ csv seperated names of queue the worker belongs to. | 147 | 4 _QUEUES_ csv seperated arrays containing an int and a string for weight and name. e.g. [40, 'email'] |
| 148 | 5 worker type of peer connecting | 148 | 5 worker type of peer connecting |
| 149 | ====== ============== =========== | 149 | ====== ============== =========== |
| 150 | 150 | ||
| @@ -203,7 +203,6 @@ Heartbeating | |||
| 203 | * If the worker detects that the broker disconnected it SHOULD restart the conversation. | 203 | * If the worker detects that the broker disconnected it SHOULD restart the conversation. |
| 204 | * If the broker detects that a worker has disconnected it should stop sending it a message of any type. | 204 | * If the broker detects that a worker has disconnected it should stop sending it a message of any type. |
| 205 | * If the scheduler detects that the broker disconnects it SHOULD restart the conversation. | 205 | * If the scheduler detects that the broker disconnects it SHOULD restart the conversation. |
| 206 | * If the broker detects that a scheduler has disconnected it should ??????????. | ||
| 207 | 206 | ||
| 208 | REQUEST Headers | 207 | REQUEST Headers |
| 209 | --------------- | 208 | --------------- |