def __init__(self, cur_job_dict, logger=None, debug=False):

        # Load Params:
        self.m_config           = cur_job_dict
        self.m_log              = logger
        self.m_debug            = debug

        # Init Members:
        self.m_status           = "Not Connected"

        # Assign from Config:
        self.m_app_config       = self.m_config["Rabbit"]
        self.m_broker_config    = self.m_config["BrokerEntities"]
        self.m_consumer_config  = self.m_config["Consumers"]

        self.m_name             = str(self.m_app_config["Name"])
        self.m_host_list        = str(self.m_app_config["BrokerAddress"][0])
        self.m_url              = str(self.m_app_config["BrokerURL"])
        self.m_exchanges        = self.m_broker_config["Exchanges"]
        self.m_queues           = self.m_broker_config["Queues"]
        self.m_messages         = self.m_broker_config["Messages"]
        self.m_bindings         = self.m_broker_config["Bindings"]
        self.m_consumers        = []
        self.m_num_consumers    = 0
        self.m_con_script       = ""
        self.m_con_interval     = ""
        self.m_con_prefix_name  = ""
        self.m_con_pid_dir      = ""
        self.m_con_tmp_dir      = ""
        self.m_consume_queues   = {}

        self.m_sent_messages    = {}
        self.m_recv_messages    = {}
        self.m_cur_message      = {}
        
        self.m_connection       = None
        self.m_channel          = None
        self.m_deliveries       = []
        self.m_acked            = 0
        self.m_nacked           = 0
        self.m_message_number   = 0
        self.m_active_bindings  = 0

        self.m_teardown_old     = bool(self.m_config["ResetAll"])
        self.m_publish_interval = float(self.m_config["Interval"])
        self.m_wait_interval    = float(self.m_config["CheckDone"])
        self.m_stopping         = False
        self.m_closing          = False
        self.m_run_summary      = True
        self.m_message_type     = "AMQP"
        self.m_number_to_send   = 0
        self.m_cur_count        = 0
        self.m_num_queues_done  = 0

        self.m_cur_message_template        = 0
        self.m_number_of_message_templates = len(self.m_messages)

        # Determine the total messages to receive
        self.m_num_amqp_msgs    = 0
        for msg in self.m_messages:
            if msg["MessageType"] == "AMQP":
                self.m_num_amqp_msgs    += int(msg["NumberToSend"])
        # end of determining messages

        self.m_only_publishing = False
        
        if len(self.m_exchanges) == 0 and len(self.m_queues) >= 0 and len(self.m_bindings) == 0:
            self.m_only_publishing = True

    # end of __init__
dataset/ETHPy150Open GetLevvel/message-simulator/src/rabbit_message_publisher.py/RabbitMessagePublisher.__init__/operator `==` -> `>=`