test_server_2.py

import pika
import logging

logging.basicConfig()

credentials = pika.PlainCredentials('zilver', 'zilver')
parameters = pika.ConnectionParameters('localhost',
                                       5673,
                                       '/',
                                       credentials)
connection = pika.BlockingConnection(parameters)
channel = connection.channel()

channel.queue_declare(queue='hello')

print ' [*] Waiting for messages. To exit press CTRL+C'

def callback(ch, method, properties, body):
    print " [x] Received %r" % (body,)

channel.basic_consume(callback,
                      queue='hello',
                      no_ack=True)

channel.start_consuming()