def METHOD_NAME(self, message):
    associated_queue = message_type(message)
    if associated_queue == 'default':
        return
    if self.queues[associated_queue].full():
        self.flush_to_quickwit()
    self.queues[associated_queue].put(message)