没有项目描述

aioamqp-ext的Python项目详细描述


#异步amqp基本使用者和生产者。

amqp使用者和生产者基类。在“aioamqp”之上工作。



路由密钥='bar'

producer.close()


使用者:

'url':'amqp://localhost:5672/',
'exchange':'my'exchange',
'queue':'my'u queue',
'routing'u key':'foo.bar'
})
尝试:
loop=asyncio.get'u event'loop()
循环。运行直至完成(consumer.consume())
循环。永远运行(
除了键盘中断:
loop.run廑until廑complete(consumer.close())
最后:
loop.close()

\tests


要运行测试,需要安装python测试依赖项::

pip install-r./requirements-ci.txt

,然后可以使用“make unit test”运行测试。

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java如何获取所有链接并使用SeleniumWebDriver逐个单击这些链接   java中数组列表的arraylist移位元素   java如何存储具有不同类型参数的元素   java不能使用List<Future<?>>当从不同位置调用时,在方法参数中   java我应该如何修复代码以避免测试代码出错?   安卓 PreferenceFragment java。lang.RuntimeException   java在运行emulator时发现错误   java取消多个AsyncTask回调的有效方法是什么?如果中途满足条件,这些回调将在将来返回?   有没有办法在运行时将方法动态分配给Java类?   java如何将propertyfile与GlassFish一起使用   如何在PHP中使用bcrypt对密码进行哈希处理?   Java和UDP web服务器   java JPA允许EntityListeners执行JPA操作吗?   java执行do while语句时不会产生错误   java无法在edittext中显示数据库中的数据   java Tomcat中活动会话的数量   java在何处使用@SuppressWarnings(“requestfactory”)   netty连接中的java HornetQ异常