#NEWLINE# def _start_pushers( self , pushers ) : #NEWLINE# #INDENT# logger . info ( 'Starting %d pushers' , len ( pushers ) ) #NEWLINE# for pusherdict in pushers : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# p = self . _create_pusher ( pusherdict ) #NEWLINE# #UNINDENT# except PusherConfigException : #NEWLINE# #INDENT# logger . exception ( "Couldn't start a pusher: caught PusherConfigException" ) #NEWLINE# continue #NEWLINE# #UNINDENT# if p : #NEWLINE# #INDENT# fullid = ( '%s:%s:%s' % ( pusherdict [ 'app_id' ] , pusherdict [ 'pushkey' ] , pusherdict [ 'user_name' ] ) ) #NEWLINE# if ( fullid in pusherdict . pushers ) : #NEWLINE# #INDENT# self . pushers [ fullid ] . stop ( ) #NEWLINE# #UNINDENT# self . pushers [ fullid ] = p #NEWLINE# preserve_fn ( p . start ) ( ) #NEWLINE# #UNINDENT# #UNINDENT# logger . info ( 'Started pushers' )