def onReceiveTestCaseRunResponse(self, ch, method, properties, body):
        logging.info("Received from the secondary client: %s " % body)
        ch.stop_consuming()
        if body == ClientMessageConsts.TASK_FAILED:
            raise AssertionError("Secondary worker failed to execute the test")
dataset/ETHPy150Open azoft-dev-team/imagrium/src/core/testcase.py/AppTestCase.onReceiveTestCaseRunResponse/original