if not queue_empty:
    method, properties, body = channel.basic_get(queue, no_ack=True)
callback_func(channel, method, properties, body)
Как использовать сообщения RabbitMQ через pika в течение ограниченного времени?