Show More
@@ -1163,7 +1163,7 b' class Hub(SessionFactory):' | |||||
1163 | # send the messages |
|
1163 | # send the messages | |
1164 | for rec in records: |
|
1164 | for rec in records: | |
1165 | header = rec['header'] |
|
1165 | header = rec['header'] | |
1166 | msg = self.session.msg(header['msg_type']) |
|
1166 | msg = self.session.msg(header['msg_type'], parent=header) | |
1167 | msg_id = msg['msg_id'] |
|
1167 | msg_id = msg['msg_id'] | |
1168 | msg['content'] = rec['content'] |
|
1168 | msg['content'] = rec['content'] | |
1169 |
|
1169 | |||
@@ -1177,7 +1177,7 b' class Hub(SessionFactory):' | |||||
1177 |
|
1177 | |||
1178 | resubmitted[rec['msg_id']] = msg_id |
|
1178 | resubmitted[rec['msg_id']] = msg_id | |
1179 | self.pending.add(msg_id) |
|
1179 | self.pending.add(msg_id) | |
1180 | msg['buffers'] = [] |
|
1180 | msg['buffers'] = rec['buffers'] | |
1181 | try: |
|
1181 | try: | |
1182 | self.db.add_record(msg_id, init_record(msg)) |
|
1182 | self.db.add_record(msg_id, init_record(msg)) | |
1183 | except Exception: |
|
1183 | except Exception: |
General Comments 0
You need to be logged in to leave comments.
Login now