Python Pika callback не работает с SelectConnection внутри класса

Question

Я пытаюсь создать простой Python Pica SelectConnection, и кажется, что я не могу открыть соединение с помощью on_open_callback, и я ничего не получаю от te on_open_error_callback либо , Может кто-нибудь предположить, что может вызвать проблему?

import pika 

class RabbitmqTransport(object): 

    def __init__(self): 

     self._connection = None 
     self._channel = None 
     self._connect() 

    def on_connection_open(self): 
     print "connection created" 

    def on_connection_open_error(self): 
     print "connection open error" 

    def _connect(self): 
     # Setup RabbitMQ connection 
     credentials = pika.PlainCredentials('guest','guest') 
     parameters = pika.URLParameters('amqp://guest:guest@localhost:5672/%2F') 


     print "Creating Connection" 
     self._connection = pika.SelectConnection(parameters=parameters,on_open_callback=self.on_connection_open,on_open_error_callback=self.on_connection_open_error) 
     print self._connection.connection_state 
     print dir(self._connection) 
     print self._connection.is_open 

r = RabbitmqTransport() 

Answer 1

Обнаружена проблема, я добавил строку ниже, а затем соединение было открыто и обратный вызов работал.

self._connection.ioloop.start()