Method
on_message
(ch, method_frame, _header_frame, body, args)
Source from the content-addressed store, hash-verified
| 63 | |
| 64 | @staticmethod |
| 65 | def on_message(ch, method_frame, _header_frame, body, args): |
| 66 | (conn, thrds) = args |
| 67 | delivery_tag = method_frame.delivery_tag |
| 68 | t = threading.Thread(target = SchedulerConsumer.process_new_event, args = (conn, ch, delivery_tag, body)) |
| 69 | t.start() |
| 70 | thrds.append(t) |
| 71 | |
| 72 | @staticmethod |
| 73 | def process_new_event(channel, method, properties, msg): |
Callers
nothing calls this directly
Tested by
no test coverage detected