(conn, ident, message)
| 91 | logger.info(f"start_snakemq messaging: {messaging}") |
| 92 | |
| 93 | def on_recv(conn, ident, message): |
| 94 | logger.info(f"start_snakemq ident: {ident}") |
| 95 | if ident == config.IDENT_MAIN: |
| 96 | message = json.loads(message.data.decode("utf-8")) |
| 97 | logger.info("json.loads: %s" % message["value"]) |
| 98 | |
| 99 | if message["type"] == "execute": |
| 100 | logger.info("Executing command: %s" % message["value"]) |
| 101 | kc.execute(message["value"]) |
| 102 | # Try direct flush with default wait (0.2) |
| 103 | flush_kernel_msgs(kc) |
| 104 | |
| 105 | messaging.on_message_recv.add(on_recv) |
| 106 |
nothing calls this directly
no test coverage detected