rename consume_msg_callback to consumer_function