pika/rabbitMQ basic worker pattern

gistfile1.py

import pika
class GenericWorker:
  def __init__(self,url='amqp://admin:password@localhost:5672/%2F'):
    self.connection = pika.BlockingConnection(pika.URLParameters(url))
    self.channel = self.connection.channel()
    self.channel.exchange_declare(exchange='TestExchange',exchange_type='direct',passive=False,durable=False)
    self.channel.queue_declare(queue='TestQueue')
    self.channel.queue_bind(queue='TestQueue',exchange='TestExchange',routing_key='TestQueueRoute')

  def run(self):
    self.channel.basic_consume(self.callback,queue='TestQueue')
    self.channel.start_consuming()

  def callback(self, channel, method_frame, header_frame, body):
    print "Entered Callback with body=", body
    print "Exited Callback gracefully"

  def publish(self,payload):
    self.channel.basic_publish('TestExchange','TestQueueRoute',payload)

W = GenericWorker()
W.run()