+
-
-
-
+
+
+
+
+
+
+
+
-
+
- jobmanager – Job Manager¶An INFORM command consists of a 5-frame multipart message, formatted as follows.
| FRAME | @@ -159,7 +243,7 @@|||
|---|---|---|---|
| 2 | INFORM | -+ | command |
| 3 | _MSGID_ | @@ -167,7 +251,7 @@||
| 4 | _QUEUE_NAME_ | -the name of the queue the worker belongs to | +csv seperated names of queue the worker belongs to |
A HEARTBEAT frame consists of a
+| FRAME | +Value | +Description | +
|---|---|---|
| 0 | +_EMPTY_ | +leave empty | +
| 1 | +eMQP/1.0 | +Protocol version | +
| 2 | +HEARTBEAT | +command | +
| 3 | +_MSGID_ | +A unique id for the msg | +
A DISCONNECT frame consists of
+| FRAME | +Value | +Description | +
|---|---|---|
| 0 | +_EMPTY_ | +leave empty | +
| 1 | +eMQP/1.0 | +Protocol version | +
| 2 | +DISCONNECT | +command | +
| 3 | +_MSGID_ | +A unique id for the msg | +
++
+- HEARTBEAT commands are valid at any time after an INFORM command
+- Any command except DISCONNECT act as a heartbeat. Peers SHOULD NOT send HEARTBEAT commands while sending other commands.
+- 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.
+
receiver – Receiver¶router – Router¶jobmanager – Job Manager","EventMQ Protocol Specification","receiver – Receiver","router – Router","sender – Sender"],titleterms:{address:2,architectur:2,client:2,document:0,emqp:2,eventmq:[0,2],goal:2,indic:0,job:1,jobmanag:1,languag:2,licens:2,manag:1,protocol:2,receiv:3,router:[2,4],sender:5,specif:2,tabl:0,topolog:2,welcom:0,worker:2}})
\ No newline at end of file
+Search.setIndex({envversion:46,filenames:["index","jobmanager","protocol","receiver","router","sender"],objects:{"eventmq.jobmanager":{JobManager:[1,3,1,""]},"eventmq.jobmanager.JobManager":{"__init__":[1,2,1,""],"__weakref__":[1,1,1,""]},"eventmq.receiver":{Receiver:[3,3,1,""]},"eventmq.receiver.Receiver":{"__init__":[3,2,1,""],"__weakref__":[3,1,1,""],connect:[3,2,1,""],listen:[3,2,1,""],name:[3,1,1,""],ready:[3,1,1,""],zcontext:[3,1,1,""],zsocket:[3,1,1,""]},"eventmq.router":{Router:[4,3,1,""]},"eventmq.router.Router":{"__weakref__":[4,1,1,""],start:[4,2,1,""]},"eventmq.sender":{Sender:[5,3,1,""]},"eventmq.sender.Sender":{"__init__":[5,2,1,""],"__weakref__":[5,1,1,""],connect:[5,2,1,""],listen:[5,2,1,""],name:[5,1,1,""],ready:[5,1,1,""],send:[5,2,1,""],send_raw:[5,2,1,""],zsocket:[5,1,1,""]},eventmq:{jobmanager:[1,0,0,"-"],receiver:[3,0,0,"-"],router:[4,0,0,"-"],sender:[5,0,0,"-"]}},objnames:{"0":["py","module","Python module"],"1":["py","attribute","Python attribute"],"2":["py","method","Python method"],"3":["py","class","Python class"]},objtypes:{"0":"py:module","1":"py:attribute","2":"py:method","3":"py:class"},terms:{"0mq":[2,5],"__init__":[1,3,5],"__weakref__":[1,3,4,5],"_empty_":2,"_headers_":2,"_msg_":2,"_msgid_":2,"_queue_name_":2,"abstract":2,"case":2,"class":[1,3,4,5],"default":[1,3,5],"function":3,"public":2,"return":[3,5],"true":[3,5],"while":2,about:1,accept:2,act:2,addr:[3,5],address:[],after:2,agre:2,all:[1,2,3,5],allow:2,alpha:2,ani:2,api:2,applic:2,architectur:[],arg:[1,3,4,5],avail:[3,5],backend_addr:4,basi:2,befor:2,begin:4,belong:2,below:2,between:2,bool:[3,5],both:2,broker:2,build:5,built:2,bulid:3,call:3,callabl:3,can:2,chang:2,check:[3,5],client:[],command:2,compon:2,connction:[3,5],connect:[2,3,4,5],consist:2,contain:2,content:0,context:[3,5],convers:2,creat:[3,5],csv:2,current:[3,5],dealer:5,debug:2,defin:[1,2,3,4,5],deliv:2,describ:2,descript:2,detail:2,detect:2,determin:2,dialog:2,dictionari:2,directli:5,disconnect:2,distribut:2,either:2,empti:2,emqp:[],ensur:1,even:2,eventloop:[1,3,4,5],except:[2,3,5],execut:2,expos:1,extra:2,fair:2,fals:[3,5],first:2,fit:2,follow:2,format:2,foundat:2,frame:2,free:2,from:2,frontend_addr:4,gener:[1,2,3,5],gnu:2,goal:[],handl:2,header:2,heartbeat:[],heavi:2,here:2,hope:2,html:2,http:2,ident:2,ietf:2,implement:2,impli:2,includ:2,index:0,inform:2,insert:2,instanc:1,interpret:2,interv:2,issu:2,job:[],jobmanag:[],kei:2,kwarg:[1,3,4,5],languag:[],later:2,least:2,leav:2,licens:[],list:[1,3,4,5],listen:[3,4,5],mai:2,main:1,manag:[],manual:2,master:2,merchant:2,messag:[2,3,4,5],method:3,modifi:2,modul:0,more:2,msg:2,multipart:2,must:2,name:[1,2,3,4,5],none:[3,5],note:[1,3,5],object:[1,3,4,5],onli:[3,5],option:[1,2,3,5],org:2,orient:2,origin:2,other:2,otherwis:[1,3,5],page:0,paramet:[1,3,4,5],part:2,particular:[2,5],pass:[2,3],peer:2,pictur:2,poll:[3,5],pool:2,portion:1,prepend:2,pretti:2,process:2,properti:[3,5],protocol:[],provid:4,pub:2,publish:2,purpos:2,queue:[2,4,5],rais:[3,5],raw:5,raw_messag:5,readi:[2,3,5],receiv:[],recent:2,reciev:3,recommend:2,redistribut:2,refer:[1,3,4,5],regular:2,reliabl:2,remov:2,rep:3,repli:2,req:5,request:[2,4],requir:[2,3],resourc:[1,2],respond:2,respons:[1,3,5],restart:2,rfc2119:2,rfc:2,robin:2,round:2,rout:[2,4],router:[],run:1,search:0,see:2,send:[2,5],send_raw:5,sender:[],seper:2,serv:2,server:[1,2],servic:2,set:[2,3,5],shall:2,should:[2,3,5],shown:2,simpl:4,singl:2,skip:[3,5],skip_zmqstream:[3,5],socket:[2,3,5],softwar:2,someth:5,spawn:1,specif:[],specifi:2,start:[3,4,5],statu:2,stop:2,str:[1,3,5],string:[3,4,5],sub:2,subject:2,subset:2,tcp:4,term:2,them:3,thi:[1,2,3,4,5],thing:1,through:2,time:2,tool:2,topic:5,topolog:[],tornado:[1,4],trace:2,tupl:5,type:[2,3,5],typeerror:3,under:2,uniqu:[1,2],unless:[1,3,5],unus:3,upon:2,uuid:[1,3,5],valid:2,valu:2,version:2,via:[3,5],warranti:2,weak:[1,3,4,5],web:2,well:2,when:[2,3,5],where:2,without:2,word:2,worker:[],wrap:[3,5],you:2,your:2,zcontext:[3,5],zeromq:2,zmq:[2,3,5],zmqstream:[3,5],zsocket:[3,5]},titles:["Welcome to EventMQ’s documentation!","jobmanager – Job Manager","EventMQ Protocol Specification","receiver – Receiver","router – Router","sender – Sender"],titleterms:{address:2,architectur:2,client:2,document:0,emqp:2,eventmq:[0,2],goal:2,heartbeat:2,indic:0,job:1,jobmanag:1,languag:2,licens:2,manag:1,protocol:2,receiv:3,router:[2,4],sender:5,specif:2,tabl:0,topolog:2,welcom:0,worker:2}})
\ No newline at end of file
diff --git a/sender.html b/sender.html
index 57f5345..8e7b660 100644
--- a/sender.html
+++ b/sender.html
@@ -1,52 +1,133 @@
-
-
-
-
-
- sender – Sender¶