轻量级消息队列、服务总线ZBUS之Python客户端

from zbus import SingleBroker, Producer, Message
broker = SingleBroker(host = 'localhost', port = 15555)

#Producer是轻量级对象,不需要关闭
p = Producer(broker=broker, mq='MyMQ') 

msg = Message()    
msg.set_body('hello world') 
print p.send(msg)


broker.destroy()

from zbus import SingleBroker, Consumer
broker = SingleBroker(host = 'localhost', port = 15555)

consumer = Consumer(broker=broker,mq='MyMQ') 

 
while True:
    msg = consumer.recv()
    if msg is None: continue
    print msg