'Removes WellKnownFlow messages from the queue and returns them.'

def FetchAndRemoveRequestsAndResponses(self, session_id):

    messages = []
    with queue_manager.WellKnownQueueManager(token=self.token) as manager:
        for response in manager.FetchResponses(session_id):
            messages.append(response)
        manager.DeleteWellKnownFlowResponses(session_id, messages)
    return messages
