我正在使用 python 并在我所做的类的方法中使用
self.connection = pika.SelectConnection(
self.connectionParameters,
on_open_callback=self.onConnected,
on_open_error_callback=self.onConnectionError,
on_close_callback=self.onConnectionClosed,
stop_ioloop_on_close=False)
在我的源代码中,我将该方法声明为(在类内):
def onConnectionError(self):
"""
@summary: Called if the connection to rabbit is unavailable. Attempt to connect to one of
the many backup servers.
@return: ??
"""
但是在运行时我收到以下错误:
Traceback (most recent call last):
File "SpaceListener.py", line 218, in <module>
cacheTime=args.timeout)
File "SpaceListener.py", line 88, in __init__
logger=self.logger)
File "/home/centos/house/tes/castExchangeScan.py", line 108, in __init__
stop_ioloop_on_close=False)
File "build/bdist.linux-i686/egg/pika/adapters/select_connection.py", line 51, in __init__
File "build/bdist.linux-i686/egg/pika/adapters/base_connection.py", line 62, in __init__
File "build/bdist.linux-i686/egg/pika/connection.py", line 590, in __init__
File "build/bdist.linux-i686/egg/pika/connection.py", line 707, in connect
File "build/bdist.linux-i686/egg/pika/callback.py", line 61, in wrapper
File "build/bdist.linux-i686/egg/pika/callback.py", line 92, in wrapper
File "build/bdist.linux-i686/egg/pika/callback.py", line 232, in process
TypeError: onConnectionError() takes exactly 1 argument (2 given)
[centos@localhost ~/house/test]$
我无法找到任何显示此回调的实际方法签名的文档。我怀疑它正在寻找该方法的非类定义(即没有 self 作为参数)。那是对的吗?如果是这样的话?那么我如何访问类变量,以便在连接错误时尝试重新连接?
我想我首先要寻找的是我的方法签名应该是什么样子?
提前致谢
最佳答案
看来我能够通过对代码进行以下转换来回答我自己的问题。
通过转换我的代码来执行以下操作:
self.connection = pika.SelectConnection(self.connectionParameters,
on_open_callback=self.onConnected, on_close_callback=self.onConnectionClosed,
stop_ioloop_on_close=False)
self.connection.add_on_open_error_callback(self.onConnectionError)
它给了我一个新的崩溃地址,现在它指向 pika 中的新一行源代码:
File "build/bdist.linux-i686/egg/pika/adapters/select_connection.py", line 51, in __init__
File "build/bdist.linux-i686/egg/pika/adapters/base_connection.py", line 62, in __init__
File "build/bdist.linux-i686/egg/pika/connection.py", line 590, in __init__
File "build/bdist.linux-i686/egg/pika/connection.py", line 707, in connect
File "build/bdist.linux-i686/egg/pika/callback.py", line 61, in wrapper
File "build/bdist.linux-i686/egg/pika/callback.py", line 92, in wrapper
File "build/bdist.linux-i686/egg/pika/callback.py", line 232, in process
File "build/bdist.linux-i686/egg/pika/connection.py", line 1192, in _on_connection_error
pika.exceptions.AMQPConnectionError: 1
查看connection.py,它会产生预期的on_connection_error 方法签名
def _on_connection_error(self, connection_unused):
"""Default behavior when the connecting connection can not connect.
:raises: exceptions.AMQPConnectionError
"""
raise exceptions.AMQPConnectionError(self.params.connection_attempts)
所以,尽管我的情况同样糟糕,但我显然现在已经有了我正在寻找的方法签名。
关于python - 鼠兔的 on_open_error_callback 方法签名是什么样的?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/19255014/