commit | f77966eb91138f981abad91dc9c3e2229c737106 | [log] [tgz] |
---|---|---|
author | Heng Du <duhengforever@apache.org> | Wed Nov 06 18:45:02 2019 +0800 |
committer | GitHub <noreply@github.com> | Wed Nov 06 18:45:02 2019 +0800 |
tree | f86f308dc30443abb5b3dc0573d22997f7885341 | |
parent | ccfb226d0f9a656cae108c1c567f38dc5e5520fe [diff] | |
parent | 1226f5d34007d003390b88afd0ce8a5fc6123f8f [diff] |
Merge pull request #71 from duhenglucky/ctypes_docs docs(readme) fix the pypi link to rocketmq-client-python
RocketMQ Python client, based on rocketmq-client-cpp, supports Linux and macOS
pip install rocketmq-client-python
from rocketmq.client import Producer, Message producer = Producer('PID-XXX') producer.set_namesrv_addr('127.0.0.1:9876') 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_addr('127.0.0.1:9876') consumer.subscribe('YOUR-TOPIC', callback) consumer.start() while True: time.sleep(3600) consumer.shutdown()
Apache License, Version 2.0 Copyright (C) Apache Software Foundation