rocketmq-python

rocketmq-python copied to clipboard

messense

消费失败重试机制不起作用

4

def test_push_consumer_reconsume_later(): stop_event = threading.Event() raised_exc = threading.Event() def on_message(msg): print(msg.body.decode('utf-8')) if not raised_exc.is_set(): raised_exc.set() raise Exception('Should reconsume later') stop_event.set() consumer = PushConsumer('xxxx') consumer.set_namesrv_domain('http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet') # For ip and port name...

q2044757581