A process is launched within the callback function, and an error occurs when attempting to send an MQ message within that process. #147

from multiprocessing import Process
from rocketmq.client import Producer, Message, PushConsumer, ConsumeStatus
import time
import json

def rmq_consumer():
    consumer = PushConsumer('group_demo')
    consumer.set_name_server_address('10.13.2.12:9876')
    consumer.subscribe('start_or_end_detect', send_message, "*")
    print(' [Consumer] Waiting for messages.')
    consumer.start()
    while True:
        time.sleep(1)

def start_pro():
    producer = Producer('test_producer')
    producer.set_name_server_address('10.13.2.12:9876')
    producer.start()
    try:
        event = {"aa": "vv", "bb": 33}
        msg = Message("fireMsg")
        ss = json.dumps(event).encode('utf-8')
        msg.set_body(ss)
        producer.send_sync(msg)

    finally:
        producer.shutdown()

def send_message():
    i = Process(target=start_pro)
    i.start()

    return ConsumeStatus.CONSUME_SUCCESS


if __name__ == '__main__':
    rmq_con = Process(target=rmq_consumer)