apache / apache/rocketmq-client-python

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

Đang mở
#114 6 bình luận 0 reaction 0 người được giao Xem trên GitHub
question
Ngôn ngữ chính
Python
Star
305
Fork
98
Chỉ số merge pull request
Không có pull request nào được merge trong 30 ngày

Mô tả

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)
```

Hướng dẫn đóng góp

Mở hướng dẫn đóng góp

Đánh giá

Issue này chưa được đánh giá.

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.