Publish and scribe redis message in python

redis-mq.py

from multiprocessing import Process
import time
import redis

# publish random message 
def pub(myredis):
    for n in range(10):
        myredis.publish('channel_rand','blah %d' % n)
        time.sleep(1)

# subscribe messages
def sub(myredis, name):
    pubsub = myredis.pubsub()
    pubsub.subscribe(['channel_rand'])
    for item in pubsub.listen():
        if item['type'] == 'message':
            print ('%s : %s' % (name, item['data']))

if __name__ == '__main__':
    myredis = redis.Redis()
    Process(target=sub, args=(myredis,'reader1')).start()
    Process(target=sub, args=(myredis,'reader2')).start()
    Process(target=pub, args=(myredis,)).start()