def start_consumers_for_queue(prefix_name="<STR_LIT>",<EOL>num_workers=<NUM_LIT:2>,<EOL>tasks=None,<EOL>queue_to_consume=None,<EOL>shutdown_msg="<STR_LIT>",<EOL>consumer_class=None,<EOL>need_response=False,<EOL>callback=None):
consumers = []<EOL>if not consumer_class:<EOL><INDENT>log.error("<STR_LIT>")<EOL>log.error("<STR_LIT>")<EOL>return consumers<EOL><DEDENT>if not tasks:<EOL><INDENT>log.error("<STR_LIT>")<EOL>return consumers<EOL><DEDENT>if not queue_to_consume:<EOL><INDENT>log.error("<STR_LIT>")<EOL>return consumers<EOL><DEDENT>log.info(("<STR_LIT>")<EOL>.format(multiprocessing.cpu_count(),<EOL>num_workers))<EOL>for i in range(num_workers):<EOL><INDENT>consumers.append(consumer_class(<EOL>"<STR_LIT>".format(prefix_name,<EOL>i + <NUM_LIT:1>),<EOL>tasks,<EOL>queue_to_consume,<EOL>shutdown_msg=shutdown_msg,<EOL>need_response=need_response,<EOL>callback=callback))<EOL><DEDENT>log.info("<STR_LIT>".format(len(consumers)))<EOL>for w in consumers:<EOL><INDENT>w.start()<EOL><DEDENT>return consumers<EOL>
start_consumers_for_queue

    :param prefix_name:
    :param num_workers:
    :param tasks:
    :param queue_to_consume:
    :param shutdown_msg:
    :param consumer_class:
    :param need_response:
    :param callback: