'For WellKnownFlows we receive these messages directly.'

def ProcessResponses(self, responses, thread_pool):

    for response in responses:
        thread_pool.AddTask(target=self._SafeProcessMessage, args=(response,), name=self.__class__.__name__)
