#NEWLINE# def notConnected( self , msg ) : #NEWLINE# #INDENT# "I can't connect to a publisher; I'll now reply to all pending\n        requests.\n        " #NEWLINE# log . msg ( ( 'could not connect to distributed web service: %s' % request ) ) #NEWLINE# self . waiting = 0 #NEWLINE# self . publisher = None #NEWLINE# for request in self . pending : #NEWLINE# #INDENT# request . write ( 'Unable to connect to distributed server.' ) #NEWLINE# request . finish ( ) #NEWLINE# #UNINDENT# self . pending = [ ]