@asyncio.coroutine<EOL>def hello_world():
<EOL>connection = yield from asynqp.connect('<STR_LIT:localhost>', <NUM_LIT>, username='<STR_LIT>', password='<STR_LIT>')<EOL>channel = yield from connection.open_channel()<EOL>exchange = yield from channel.declare_exchange('<STR_LIT>', '<STR_LIT>')<EOL>queue = yield from channel.declare_queue('<STR_LIT>')<EOL>yield from queue.bind(exchange, '<STR_LIT>')<EOL>msg = asynqp.Message({'<STR_LIT:hello>': '<STR_LIT>'})<EOL>exchange.publish(msg, '<STR_LIT>')<EOL>received_message = yield from queue.get()<EOL>print(received_message.json())  <EOL>received_message.ack()<EOL>yield from channel.close()<EOL>yield from connection.close()<EOL>
Sends a 'hello world' message and then reads it from the queue.