pika-pool 0.1.3

用法

得到它：

pip install pika-pool

使用它：

importjsonimportpikaimportpika_poolparams=pika.URLParameters('amqp://guest:guest@localhost:5672/?''socket_timeout=10&''connection_attempts=2')pool=pika_pool.QueuedPool(create=lambda:pika.BlockingConnection(parameters=params),max_size=10,max_overflow=10,timeout=10,recycle=3600,stale=45,)withpool.acquire()ascxn:cxn.channel.basic_publish(body=json.dumps({'type':'banana','description':'they are yellow'}),exchange='',routing_key='fruits',properties=pika.BasicProperties(content_type='application/json',content_encoding='utf-8',delivery_mode=2,))

释放

测试通过：

py.test test.py --cov=pika_pool --cov-report term-missing

所以更新__version__in:

• __init__.py

然后提交并标记它：

git commit -am "release v{version}"
git tag -a v{version} -m "release v{version}"
git push --tags

并且travis将它发布到pypi。