[Python] AMQPConnectionError using Pika and RabbitMQ with Asyncore - why?

Why am I getting an AMQPConnectionError with Asyncore but not with BlockingConnection?

If it's just 'Asyncore doesn't work in Windows' then so be it, though I've yet to find anything that forbids its use. (This issue is platform independent.) For ease of migration I'd like to use async libraries that are available on both Python 2.7 and Python 3.4, and Asyncore should work here.

I'm using RabbitMQ 3.2.4 with Python 2.7.6 and pika 0.9.13. User and admin run level didn't make a difference. Logger's presence or absence in the code has no bearing on the error, except the updated warning message above. Same error is seen in Linux (Ubuntu 14.04) and Windows 7, so it's not a platform problem.

Because the performance of pika is rather poor using BlockingConnection, I wanted to try the Asyncore adapter instead. Seems pretty straightforward for a testbed setup (I tried giving it credentials though that shouldn't matter and the callbacks are stubbed out if not given... it fails either way.):

With BlockingConnection per the tutorial - it works, but has low throughput:

connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))


With AsyncoreConnection - all variants of this that I've tried fail immediately:

connection = pika.AsyncoreConnection(pika.ConnectionParameters(host='localhost'))


The error:

WARNINGika.connection:Could not connect, 0 attempts left
Traceback (most recent call last):
File "C:\workspace\send.py", line 8, in <module>
connection = pika.AsyncoreConnection(pika.ConnectionParameters(host='localhost'))
File "C:\Python27\lib\site-packages\pika\adapters\asyncore_connection.py", line 135, in __init__
stop_ioloop_on_close)
File "C:\Python27\lib\site-packages\pika\adapters\base_connection.py", line 62, in __init__
on_close_callback)
File "C:\Python27\lib\site-packages\pika\connection.py", line 590, in __init__
self.connect()
File "C:\Python27\lib\site-packages\pika\connection.py", line 707, in connect
self.callbacks.process(0, self.ON_CONNECTION_ERROR, self, self)
File "C:\Python27\lib\site-packages\pika\callback.py", line 61, in wrapper
return function(*tuple(args), **kwargs)
File "C:\Python27\lib\site-packages\pika\callback.py", line 92, in wrapper
return function(*args, **kwargs)
File "C:\Python27\lib\site-packages\pika\callback.py", line 232, in process
callback(*args, **keywords)
File "C:\Python27\lib\site-packages\pika\connection.py", line 1192, in _on_connection_error
raise exceptions.AMQPConnectionError(self.params.connection_attempts)
pika.exceptions.AMQPConnectionError: 1

Continue reading...