(ch, method, properties, body)
| 7 | channel = connection.channel() |
| 8 | |
| 9 | def callback(ch, method, properties, body): |
| 10 | err = email.notification(body) |
| 11 | if err: |
| 12 | ch.basic_nack(delivery_tag=method.delivery_tag) |
| 13 | else: |
| 14 | ch.basic_ack(delivery_tag=method.delivery_tag) |
| 15 | |
| 16 | channel.basic_consume( |
| 17 | queue=os.environ.get("MP3_QUEUE"), on_message_callback=callback |
nothing calls this directly
no outgoing calls
no test coverage detected