def start_worker_publisher(self, cur_message):
        """
        Starting a Worker Publisher now that the broker entities are created
        """

        results             = build_dict("FAILED", "Worker Not Started", { })

        try:

            if self.m_channel is not None:
                results     = build_dict("FAILED", "Not Connected", { })
            else:

                pids                = []

                number_workers      = int(cur_message["NumberWorkers"])
                cur_worker          = 0
                while cur_worker < number_workers:

                    try:

                        remote_com  = cur_message["Command"]
                        log_line    = "Starting Worker(" + str(cur_worker) + ") with Command(" + str(remote_com) + ")"
                        print log_line

                        proc        = subprocess.Popen(remote_com, shell=True, stdout=subprocess.PIPE)
                        pids.append({
                                        "PID"       : str(proc.pid),
                                        "Command"   : str(remote_com)
                                    })

                    except Exception,h:
                        self.lg("Start Worker Publisher Failed with Ex(" + str(h) + ")", 6)
                        results     = build_dict("SUCCESS", "No Exchanges", { "Exchanges" : [] })
                    # end of try/ex for getting the exchanges

                    cur_worker      += 1
                # end of cur worker

                results             = build_dict("SUCCESS", "Started Workers", { "PIDs" : pids })

        except Exception,k:
            err_msg             = "Failed to perform start_worker_publisher with Ex(" + str(k) + ")"
            self.elg("ERROR: " + str(err_msg), True)
            self.m_status       = "Failed"
            results             = build_dict("FAILED", str(err_msg), { "Exchanges" : [] })
        # end of try/ex

        return results
    # end of start_worker_publisher
dataset/ETHPy150Open GetLevvel/message-simulator/src/rabbit_message_publisher.py/RabbitMessagePublisher.start_worker_publisher/operator `==` -> `is not`