Asyncio应用程序的Stompt客户端
项目描述
Aiostomp
Python 3.6的简单asyncio stomp 1.1客户端。
深受torstomp的启发。
安装
使用pip
pip install aiostomp
使用方法
import sys
import logging
import asyncio
from aiostomp import AioStomp
logging.basicConfig(
format="%(asctime)s - %(filename)s:%(lineno)d - "
"%(levelname)s - %(message)s",
level='DEBUG')
async def run():
client = AioStomp('localhost', 61613, error_handler=report_error)
client.subscribe('/queue/channel', handler=on_message)
await client.connect()
client.send('/queue/channel', body=u'Thanks', headers={})
async def on_message(frame, message):
print('on_message:', message)
return True
async def report_error(error):
print('report_error:', error)
def main(args):
loop = asyncio.get_event_loop()
loop.run_until_complete(run())
loop.run_forever()
if __name__ == '__main__':
main(sys.argv)
开发
为此项目创建一个空的虚拟环境，运行以下命令
make setup
并运行所有测试 =)
make test
贡献
分叉，修补，测试，并发送拉取请求。
下载文件
下载适合您平台的文件。如果您不确定选择哪个，请了解有关 安装软件包 的更多信息。
源分布
aiostomp-1.7.3.tar.gz (10.6 kB 查看哈希值)
构建发行版
aiostomp-1.7.3-py3-none-any.whl (11.1 kB 查看哈希值)
关闭
aiostomp-1.7.3.tar.gz的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | 5a367da55fb2ab97f419674e7fa7f3592e53ac7b435a720a6f6a4585faad360b |
|
| MD5 | 229982137e44f0679a3cd53c58dc1dc0 |
|
| BLAKE2b-256 | 315bda3ec24fe3d40b24fdbf064d7d74c2152c0a4bfbbeac4e013535f3aa4558 |
关闭
aiostomp-1.7.3-py3-none-any.whl的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | 24bb34cc707b5f979bfa028cc8c77ed1f36bd405394cfdd8c182afc27d24aec5 |
|
| MD5 | b1e2c14b74cd931c15a85759532badff |
|
| BLAKE2b-256 | fa74ea5f40bc923965c01b4bf47eda009f7eed0aac02d862c4c84fd0cf2d0fae |