def on_message(message):
    print("Message:", message.body)

    # Acknowledge that we handled the message without any issues.
    message.ack()

    # Reject the message.
    # message.reject()

    # Reject the message, and put it back in the queue.
    # message.reject(requeue=True)
This function is called on message received.
dataset/ETHPy150Open eandersson/amqpstorm/examples/simple_consumer.py/on_message