A wrapper around pika to facilitate sending and receiving RabbitMQ messages
from pellets import DurableMessenger
msgr = DurableMessenger.DurableMessenger('/path/to/creds/broker_creds.crypt') conn = msgr.get_conn() msgr.make_channel(conn, <CHANNEL_NAME>) if listen:
msgr.listen(<CHANNEL_NAME>)
- else:
- msgr.send_message(conn, <CHANNEL_NAME>, <MSG>)
msgr.close_conn(conn)
pip install pellets
pika cryptography
Python 3.9
GNU GPL v3.0
pellets was written by James parks <[email protected]>