#NEWLINE# def __init__( self , callback , **options ) : #NEWLINE# #INDENT# import redis #NEWLINE# super ( Redis , self ) . __init__ ( name = 'mutant-state-pubsub-redis-engine' ) #NEWLINE# self . callback = self #NEWLINE# self . connection = redis . StrictRedis ( ** options ) #NEWLINE# self . pubsub = self . connection . pubsub ( )