##// END OF EJS Templates
remove sub header from Session
MinRK -
Show More
@@ -405,7 +405,7 b' class Session(Configurable):'
405 405 def msg_header(self, msg_type):
406 406 return msg_header(self.msg_id, msg_type, self.username, self.session)
407 407
408 def msg(self, msg_type, content=None, parent=None, subheader=None, header=None, metadata=None):
408 def msg(self, msg_type, content=None, parent=None, header=None, metadata=None):
409 409 """Return the nested message dict.
410 410
411 411 This format is different from what is sent over the wire. The
@@ -415,8 +415,6 b' class Session(Configurable):'
415 415 msg = {}
416 416 header = self.msg_header(msg_type) if header is None else header
417 417 msg['header'] = header
418 if subheader is not None:
419 msg['header'].update(subheader)
420 418 msg['msg_id'] = header['msg_id']
421 419 msg['msg_type'] = header['msg_type']
422 420 msg['parent_header'] = {} if parent is None else extract_header(parent)
@@ -499,7 +497,7 b' class Session(Configurable):'
499 497 return to_send
500 498
501 499 def send(self, stream, msg_or_type, content=None, parent=None, ident=None,
502 buffers=None, subheader=None, track=False, header=None, metadata=None):
500 buffers=None, track=False, header=None, metadata=None):
503 501 """Build and send a message via stream or socket.
504 502
505 503 The message format used by this function internally is as follows:
@@ -529,9 +527,6 b' class Session(Configurable):'
529 527 (ignored if msg_or_type is a message).
530 528 ident : bytes or list of bytes
531 529 The zmq.IDENTITY routing path.
532 subheader : dict or None
533 Extra header keys for this message's header (ignored if msg_or_type
534 is a message).
535 530 metadata : dict or None
536 531 The metadata describing the message
537 532 buffers : list or None
@@ -563,7 +558,7 b' class Session(Configurable):'
563 558 msg = msg_or_type
564 559 else:
565 560 msg = self.msg(msg_or_type, content=content, parent=parent,
566 subheader=subheader, header=header, metadata=metadata)
561 header=header, metadata=metadata)
567 562
568 563 buffers = [] if buffers is None else buffers
569 564 to_send = self.serialize(msg, ident)
@@ -730,9 +725,9 b' class Session(Configurable):'
730 725 if signature in self.digest_history:
731 726 raise ValueError("Duplicate Signature: %r"%signature)
732 727 self.digest_history.add(signature)
733 check = self.sign(msg_list[1:4])
728 check = self.sign(msg_list[1:5])
734 729 if not signature == check:
735 raise ValueError("Invalid Signature: %r"%signature)
730 raise ValueError("Invalid Signature: %r" % signature)
736 731 if not len(msg_list) >= minlen:
737 732 raise TypeError("malformed message, must have at least %i elements"%minlen)
738 733 header = self.unpack(msg_list[1])
General Comments 0
You need to be logged in to leave comments. Login now