simple redis publisher

gistfile1.py

import redis
import threading


class Worker(threading.Thread):
    '''Generic Main Worker class'''

    def __init__(self, r, channels):
        # init super
        threading.Thread.__init__(self)

        self.redis = r

        # subscribe to given channels
        self.pubsub = self.redis.pubsub()
        self.pubsub.subscribe(channels)

    def dispatch(self, *args, **kwargs):
        '''Method for each worker to implement its "work"'''
        raise NotImplementedError()

    def run(self):
        '''Iterates published messages and dispatches them'''
        for item in self.pubsub.listen():
            self.dispatch(item)