+class SimpleConsumer(object):
+ def __init__(self, channel, consume_queue_name):
+ self.properties = pika.BasicProperties(
+ delivery_mode=2, # make message persistent
+ self.channel.queue_declare(queue=consume_queue_name, durable=True)
+ self.channel.basic_consume(self.callback,
+ queue=consume_queue_name,
+ self.channel.start_consuming()
+ def callback(self, ch: pika.adapters.blocking_connection.BlockingChannel, method, _, body):
+ ch.basic_ack(delivery_tag=method.delivery_tag)
+if __name__ == '__main__':
+ connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+ consumer = SimpleConsumer(connection.channel(), 'queue_name')
