'User id (the user for which we want to read/write notifications)'

def __init__(self, user_id, **kwargs):

    AggregatedFeed.__init__(self, user_id, **kwargs)
    self.format_dict = dict(user_id=user_id)
    self.count_key = (self.count_format % self.format_dict)
    self.pubsub_key = user_id
    self.lock_key = (self.lock_format % self.format_dict)
    from stream_framework.storage.redis.connection import get_redis_connection
    self.redis = get_redis_connection()
