Stompt Client for Asyncio applications
Project description
Aiostomp
Simple asyncio stomp 1.1 client for python 3.6.
Heavely inspired on torstomp.
Install
with pip:
pip install aiostomp
Usage
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)
Development
With empty virtualenv for this project, run this command:
make setup
and run all tests =)
make test
Contributing
Fork, patch, test, and send a pull request.
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
aiostomp-1.7.3.tar.gz
(10.6 kB
view hashes)
Built Distribution
aiostomp-1.7.3-py3-none-any.whl
(11.1 kB
view hashes)
