Description:
aiostomp 1.7.3
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.
License
For personal and professional use. You cannot resell or redistribute these repositories in their original state.
Customer Reviews
There are no reviews.
