| 123456789101112131415161718 |
- from rocketmq.client import PushConsumer
- import time
- namesrv = "172.19.193.178:9876"
- topic_name = 'topic_name'
- def callback(msg):
- print(msg)
- consumer = PushConsumer('PID-0012', message_model=0)
- consumer.set_namesrv_addr(namesrv)
- consumer.subscribe(topic_name, callback)
- consumer.start()
- while True:
- time.sleep(30)
- consumer.shutdown()
|
