apache / apache/rocketmq-client-python

I use this producer example to send transaction message to RocketMQ, why the check_callback callback function cannot execute?

未關閉
#114 6 則留言 0 個 reaction 已指派 0 人 在 GitHub 檢視
question
主要語言
Python
星號
305
分支
98
PR 合併指標
30 天內沒有已合併 PR

描述

1. Please describe the issue you observed:
I use this producer example to send transaction message to RocketMQ, why the check_callback callback function cannot execute?

2. Please tell us about your environment:

mac os

3. Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc):

```
def send_transaction_message(count):
producer = TransactionMQProducer(gid, check_callback)
producer.set_name_server_address(name_srv)
producer.start()
for n in range(count):
msg = create_message()
ret = producer.send_message_in_transaction(msg, local_execute, None)
print ('send message status: ' + str(ret.status) + ' msgId: ' + ret.msg_id)
print ('send transaction message done')

while True:
time.sleep(3600)
```

貢獻指南

開啟貢獻指南

評估

這個 Issue 還沒有評估資料。

把新 issue 寄到你的電子郵件信箱

精選適合新手參與的 GitHub issue 摘要。