1- # rocketmq-python
1+ # rocketmq-client- python
22
33[ ![ Build Status] ( https://travis-ci.org/apache/rocketmq-client-python.svg?branch=master )] ( https://travis-ci.org/apache/rocketmq-client-python )
44[ ![ codecov] ( https://codecov.io/gh/apache/rocketmq-client-python/branch/ctypes/graph/badge.svg )] ( https://codecov.io/gh/apache/rocketmq-client-python/branch/ctypes )
5- [ ![ PyPI] ( https://img.shields.io/pypi/v/rocketmq.svg )] ( https://pypi.org/project/rocketmq )
5+ [ ![ PyPI] ( https://img.shields.io/pypi/v/rocketmq-client-python .svg )] ( https://pypi.org/project/rocketmq-client-python )
66
77RocketMQ Python client, based on [ rocketmq-client-cpp] ( https://github.com/apache/rocketmq-client-cpp ) , supports Linux and macOS
88
99## Installation
1010
1111``` bash
12- pip install rocketmq
12+ pip install rocketmq-client-python
1313```
1414
1515## Usage
@@ -20,10 +20,7 @@ pip install rocketmq
2020from rocketmq.client import Producer, Message
2121
2222producer = Producer(' PID-XXX' )
23- producer.set_namesrv_domain(' http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet' )
24- # For ip and port name server address, use `set_namesrv_addr` method, for example:
25- # producer.set_namesrv_addr('127.0.0.1:9887')
26- producer.set_session_credentials(' XXX' , ' XXXX' , ' ALIYUN' ) # No need to call this function if you don't use Aliyun.
23+ producer.set_namesrv_addr(' 127.0.0.1:9876' )
2724producer.start()
2825
2926msg = Message(' YOUR-TOPIC' )
@@ -48,10 +45,7 @@ def callback(msg):
4845
4946
5047consumer = PushConsumer(' CID_XXX' )
51- consumer.set_namesrv_domain(' http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet' )
52- # For ip and port name server address, use `set_namesrv_addr` method, for example:
53- # consumer.set_namesrv_addr('127.0.0.1:9887')
54- consumer.set_session_credentials(' XXX' , ' XXXX' , ' ALIYUN' ) # No need to call this function if you don't use Aliyun.
48+ consumer.set_namesrv_addr(' 127.0.0.1:9876' )
5549consumer.subscribe(' YOUR-TOPIC' , callback)
5650consumer.start()
5751
0 commit comments