def run(self):
self._connection = self.connect()<EOL>self._connection.ioloop.start()<EOL>
Start the consumer by connecting to RabbitMQ and then starting the
        IOLoop to block and allow the SelectConnection to operate.