text: import pika
  
  connection = pika.BlockingConnection(pika.ConnectionParameters(host="localhost"))
  channel = connection.channel()
  channel.queue_declare(queue="hello")
  
  def callback(ch, method, properties, body):
      print(" [x] Received : {}".format(body))
  
  channel.basic_consume(queue="hello", on_message_callback=callback, auto_ack=True)
  print(" [*] Waiting for messages.")
  channel.start_consuming()
  