Python Pika回调不能使用类内的SelectConnection
问题描述:
我想创建一个简单的Python Pika SelectConnection,看来我无法使用on_open_callback打开连接,并且我也没有从te on_open_error_callback获取任何内容。有人可以提出可能导致问题的原因吗?Python Pika回调不能使用类内的SelectConnection
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:[email protected]: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()
答
发现问题,我添加了下面的行,然后连接打开,回调工作。
self._connection.ioloop.start()