class Fluent::MemoryBuffer

def before_shutdown(out)

def before_shutdown(out)
  synchronize do
    @map.each_key {|key|
      push(key)
    }
    while pop(out)
    end
  end
end

def configure(conf)

def configure(conf)
  super
end

def enqueue(chunk)

def enqueue(chunk)
end

def initialize

def initialize
  super
end

def new_chunk(key)

def new_chunk(key)
  MemoryBufferChunk.new(key)
end

def resume

def resume
  return [], {}
end