В моей программе есть функция обратного вызова, которая должна проверять успех / неудачу. Как я могу это сделать? В моем примере ниже, где код_отказа go? Мой фрагмент:
def mq_callback(job_id, ch, method, body):
# Do some stuff. But if the stuff fails...
return failure_code
channel.basic_consume(
queue='some queue',
on_message_callback=lambda ch, method, properties, body: mq_callback(job_id, ch, method, body),
auto_ack=False
)
channel.start_consuming()