code: def hello_world():
      
      # connect to the RabbitMQ broker
      connection = yield from asynqp.connect('localhost', 5672, username='guest', password='guest')
  
      # Open a communications channel
      channel = yield from connection.open_channel()
  
      # Create a queue and an exchange on the broker
      exchange = yield from channel.declare_exchange('test.exchange', 'direct')
      queue = yield from channel.declare_queue('test.queue')
  
      # Bind the queue to the exchange, so the queue will get messages published to the exchange
      yield from queue.bind(exchange, 'routing.key')
  
      # If you pass in a dict it will be automatically converted to JSON
      msg = asynqp.Message({'hello': 'world'})
      exchange.publish(msg, 'routing.key')
  
      # Synchronously get a message from the queue
      received_message = yield from queue.get()
      print(received_message.json())  # get JSON from incoming messages easily
  
      # Acknowledge a delivered message
      received_message.ack()
  
      yield from channel.close()
      yield from connection.close()
docs: Sends a 'hello world' message and then reads it from the queue.