Function start_snakemq

solidui/kernel_program/kernel_manager.py:87–122

(kc)

def start_snakemq(kc):
    global messaging

    messaging, link = utils.init_snakemq(config.IDENT_KERNEL_MANAGER, "connect")
    logger.info(f"start_snakemq messaging: {messaging}")

    def on_recv(conn, ident, message):
        logger.info(f"start_snakemq ident: {ident}")
        if ident == config.IDENT_MAIN:
            message = json.loads(message.data.decode("utf-8"))
            logger.info("json.loads: %s" % message["value"])

            if message["type"] == "execute":
                logger.info("Executing command: %s" % message["value"])
                kc.execute(message["value"])
                # Try direct flush with default wait (0.2)
                flush_kernel_msgs(kc)

    messaging.on_message_recv.add(on_recv)

    start_flusher(kc)

    # Send alive
    utils.send_json(messaging, {"type": "status", "value": "ready"}, config.IDENT_MAIN)
    logger.info("Python kernel ready to receive messages!")

    logger.info("Starting snakemq loop")

    try:
        link.loop()
    except KeyboardInterrupt:
        logger.info("Keyboard interrupt received, exiting...")
        sys.exit(0)
    except Exception as e:
        logger.error("Error in snakemq loop: %s" % e)
        sys.exit(1)


def start_flusher(kc):