'Flushes the messages that were queued.'

def FlushMessages(self):

    if (self.parent_runner is None):
        self.queue_manager.Flush()
    if self.queued_replies:
        with data_store.DB.GetMutationPool(token=self.token) as mutation_pool:
            for response in self.queued_replies:
                sequential_collection.GeneralIndexedCollection.StaticAdd(self.flow_obj.output_urn, self.token, response, mutation_pool=mutation_pool)
                multi_type_collection.MultiTypeCollection.StaticAdd(self.flow_obj.multi_type_output_urn, self.token, response, mutation_pool=mutation_pool)
        self.queued_replies = []
