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