'I can\'t connect to a publisher; I\'ll now reply to all pending
requests.'

def notConnected(self, msg):

    log.msg(('could    not    connect    to    distributed    web    service:    %s' % msg))
    self.waiting = 0
    self.publisher = None
    for request in self.pending:
        request.write('Unable    to    connect    to    distributed    server.')
        request.finish()
    self.pending = []
