search

apache / rocketmq-client-python

Apache RocketMQ python client
https://rocketmq.apache.org/
Apache License 2.0
274 stars 95 forks source link

pushConsumer 只用来接收消息, callback(msg) msg怎么传 #124

Closed oklooo closed 2 years ago

oklooo commented 2 years ago

pushConsumer: 读取topic中的消息进行消费，只用到接收消息模块,不需要往MQ写消息。callback(msg) 中msg 应该怎传 报错信息：TypeError: callback() missing 1 required positional argument: 'msg'