apache / apache/rocketmq-client-python

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

Aberta
#114 6 comentários 0 reações 0 responsáveis Ver no GitHub
question
Linguagem predominante
Python
Estrelas
305
Forks
98
Métricas de merge de PRs
Nenhum PR com merge em 30d

Descrição

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

Guia de contribuição

Abrir o guia de contribuição

Avaliação

Esta issue ainda não foi avaliada.

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.