PI-KA-CHU 0.1.0

a PIKA based, Cuter and more Human rabbitmq queue Utility (´_ゝ`)

PIKACHU

a PIKA based, Cuter and more Human rabbitmq queue Utility (´_ゝ`)

Simple to use

put a message into queue(independent by namespace):

import PIKACHU
PIKACHU.SimpleProducor("amqp://localhost").put(dict(data="some message"))

get some messages from queue:

for envelope in PIKACHU.SimpleConsumer("amqp://localhost").get():
    print("get message:", envelope.message)
    envelope.message_read()

use listener to listen message arrival constantly:

def callback(envelope):
    print("get message:", envelope.message)
    envelope.message_read()

consumer = PIKACHU.SimpleAsyncConsumer(settings.amqp)
ioloop = consumer.start_listen(callback)
ioloop.start()

installation

pip install git+https://github.com/smilefufu/PIKACHU@master