没有项目描述

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第三方库


热门话题
JPanel的java滚动窗格?   java JPA查询方法:findTopX,其中X是给定的(变量)数?   当应用程序在Oreo中处于后台时,java音乐服务在几秒钟后不工作   java通过TCP流发送密钥编码的字符串BadPaddingException with Windows   java在这里构建代码的更好方法是什么?   如何使用Java(无给定参数)检查列表中是否有数字   跨多个JVM的java事务控制   dataframe如何使用SparkJavaAPI的MapFunction和ReduceFunction在集群上并行处理这个问题?   java如何在多模块spring引导中配置yml文件   已安装java JDBC驱动程序,但出现异常   JUnit 4中的java,有没有一种方法可以在扩展BlockJUnit4ClassRunner的自定义运行程序中,在all@BeforeClass之前运行一段代码   继续未能选择JAVA上的radioButton   java如何通过PHP代码运行shell命令?   java JSlider SynthLookandFeel填充颜色   java给定一个数字,打印下三个数字   java SpringMVC(安全)403错误   java Graphhopper从装载的obb文件系统加载路由信息时出错   java安全工具扫描问题,发现依赖默认编码:新字符串(字节[])   java如何获取嵌套字段