Permalink
Browse files

Merge pull request #25 from inean/master

Allow custom io loops for ConnectionPool
  • Loading branch information...
2 parents c8697f4 + 402f7d3 commit 360aceeb16a40136a2eca80621c50bebe7ebdea5 @mher committed Jan 2, 2014
Showing with 1 addition and 1 deletion.
  1. +1 −1 tcelery/__init__.py
View
@@ -19,7 +19,7 @@ def setup_nonblocking_producer(celery_app=None, io_loop=None,
io_loop = io_loop or ioloop.IOLoop.instance()
NonBlockingTaskProducer.app = celery_app
- NonBlockingTaskProducer.conn_pool = ConnectionPool(limit=limit)
+ NonBlockingTaskProducer.conn_pool = ConnectionPool(limit, io_loop)
NonBlockingTaskProducer.result_cls = result_cls
if celery_app.conf['BROKER_URL'] and celery_app.conf['BROKER_URL'].startswith('amqp'):
celery.app.amqp.AMQP.producer_cls = NonBlockingTaskProducer

0 comments on commit 360acee

Please sign in to comment.