aboutsummaryrefslogtreecommitdiffstats
path: root/_sources/protocol.txt
diff options
context:
space:
mode:
Diffstat (limited to '_sources/protocol.txt')
-rw-r--r--_sources/protocol.txt13
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
711 eMQP/1.0 Protocol version 711 eMQP/1.0 Protocol version
722 REQUEST command 722 REQUEST command
733 _MSGID_ A unique id for the msg 733 _MSGID_ A unique id for the msg
744 _QUEUE_NAME_ the name of the queue the worker belongs to 744 _QUEUE_NAME_ the name of the queue the request should be sent to
755 _HEADERS_ dictionary of headers. can be an empty set 755 _HEADERS_ dictionary of headers. can be an empty set
766 _MSG_ The message to send 766 _MSG_ The message to send
77====== ============== =========== 77====== ============== ===========
@@ -85,7 +85,7 @@ FRAME Value Description
851 eMQP/1.0 Protocol version 851 eMQP/1.0 Protocol version
862 PUBLISH command 862 PUBLISH command
873 _MSGID_ A unique id for the msg 873 _MSGID_ A unique id for the msg
884 _TOPIC_NAME_ the name of the queue the worker belongs to 884 _TOPIC_NAME_ the name of the topic this message should be published across
895 _HEADERS_ csv list of headers 895 _HEADERS_ csv list of headers
906 _MSG_ The message to send 906 _MSG_ The message to send
91====== ============== =========== 91====== ============== ===========
@@ -99,7 +99,7 @@ FRAME Value Description
991 eMQP/1.0 Protocol version 991 eMQP/1.0 Protocol version
1002 SCHEDULE command 1002 SCHEDULE command
1013 _MSGID_ A unique id for the msg 1013 _MSGID_ A unique id for the msg
1024 _TOPIC_NAME_ name of queue that the job should run in 1024 _QUEUE_NAME_ name of queue that the job should run in
1035 _HEADERS_ csv list of headers for this message 1035 _HEADERS_ csv list of headers for this message
1046 _MSG_ The message to send 1046 _MSG_ The message to send
105====== ============== =========== 105====== ============== ===========
@@ -113,7 +113,7 @@ FRAME Value Description
1131 eMQP/1.0 Protocol version 1131 eMQP/1.0 Protocol version
1142 UNSCHEDULE command 1142 UNSCHEDULE command
1153 _MSGID_ A unique id for the msg 1153 _MSGID_ A unique id for the msg
1164 _TOPIC_NAME_ ignored for this command, broadcasted to all queues 1164 _QUEUE_NAME_ ignored for this command, broadcasted to all queues
1175 _HEADERS_ csv list of headers for this message 1175 _HEADERS_ csv list of headers for this message
1186 _MSG_ The message to send 1186 _MSG_ The message to send
119====== ============== =========== 119====== ============== ===========
@@ -129,7 +129,7 @@ FRAME Value Description
1291 eMQP/1.0 Protocol version 1291 eMQP/1.0 Protocol version
1302 INFORM command 1302 INFORM command
1313 _MSGID_ A unique id for the msg 1313 _MSGID_ A unique id for the msg
1324 _QUEUE_NAME_ csv seperated names of queue the worker belongs to 1324 Queues. Unused for scheduler
1335 scheduler type of peer connecting 1335 scheduler type of peer connecting
134====== ============== =========== 134====== ============== ===========
135 135
@@ -144,7 +144,7 @@ FRAME Value Description
1441 eMQP/1.0 Protocol version 1441 eMQP/1.0 Protocol version
1452 INFORM command 1452 INFORM command
1463 _MSGID_ A unique id for the msg 1463 _MSGID_ A unique id for the msg
1474 _QUEUE_NAME_ csv seperated names of queue the worker belongs to. 1474 _QUEUES_ csv seperated arrays containing an int and a string for weight and name. e.g. [40, 'email']
1485 worker type of peer connecting 1485 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
208REQUEST Headers 207REQUEST Headers
209--------------- 208---------------