snippet/listener.py
from redis import Redis
channel="channel1"
def client():
r = Redis()
p = r.pubsub()
p.subscribe(channel)
exit = False
while not exit:
for m in p.listen():
out = m['data']
print out
if isinstance(out,str) and "+CMD" in out:
break
r.publish(channel, "+SUCCESS result")
r.publish(channel, "+END result")
def server():
r = Redis("10.0.20.1")
p = r.pubsub()
p.subscribe(channel)
for cmd in ["START","PUSH","SILENT","END"]:
r.publish(channel, "+CMD %s" % cmd)
for m in p.listen():
out = m['data']
print out
if isinstance(out,str) and "+END" in out:
break