'Push messages to the input queue.'

def QueueMessages(self, messages):

    for message in messages:
        self._in_queue.put(message, block=True)
        stats.STATS.IncrementCounter('grr_client_received_messages')
