A wrapper of pika To make it's coding like flask.
Server Example:
from fliska import PikaConsumer, request
consumer = PikaConsumer(
host='localhost',
port=5672,
username='guest',
password='guest')
@consumer.channel('test')
def test_callback(ch, method, property, body):
print(request)
return ch.basic_ack(deliverty_tag=method.delivery_tag)
consumer.run()Client Example:
from fliska import PurePikaProducer
producer = PurePikaProducer(host='localhost', port=5672)
data = json.dumps({'msg': 'success', 'data': []})
producer.publish('test', data)