| commit | efc4e9b0ad558b007601e199b41bf424cdb4e96e | [log] [tgz] |
|---|---|---|
| author | messense <messense@icloud.com> | Sun Mar 24 17:10:43 2019 +0800 |
| committer | messense <messense@icloud.com> | Thu Oct 17 15:43:38 2019 +0800 |
| tree | 57f641a2bd20308a18c51ed4a5047934ab3b7f41 | |
| parent | 259a23a00d281856983c2b1b878c22911bb58fe1 [diff] |
Raise NullPointerException when producer/consumer creation failed
RocketMQ Python client
pip install rocketmq
from rocketmq.client import Producer, Message producer = Producer('PID-XXX') producer.set_namesrv_domain('http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet') producer.set_session_credentials('XXX', 'XXXX', 'ALIYUN') producer.start() msg = Message('YOUR-TOPIC') msg.set_keys('XXX') msg.set_tags('XXX') msg.set_body('XXXX') ret = producer.send_sync(msg) print(ret.status, ret.msg_id, ret.offset) producer.shutdown()
import time from rocketmq.client import PushConsumer def callback(msg): print(msg.id, msg.body) consumer = PushConsumer('CID_XXX') consumer.set_namesrv_domain('http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet') consumer.set_session_credentials('XXX', 'XXXX', 'ALIYUN') consumer.subscribe('YOUR-TOPIC', callback) consumer.start() while True: time.sleep(3600) consumer.shutdown()
from rocketmq.client import PullConsumer consumer = PullConsumer('CID_XXX') consumer.set_namesrv_domain('http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet') consumer.set_session_credentials('XXX', 'XXXX', 'ALIYUN') consumer.start() for msg in consumer.pull('YOUR-TOPIC'): print(msg.id, msg.body) consumer.shutdown()
This work is released under the MIT license. A copy of the license is provided in the LICENSE file.