Method: Agent::Queue#close

Defined in:
lib/agent/queue.rb

#close ⇒ Object 



57
58
59
60
61
62
63
64
65
 
# File 'lib/agent/queue.rb', line 57

def close
  mutex.synchronize do
    raise Errors::ChannelClosed if @closed
    @operations.each{|o| o.close }
    @closed = true

    reset_custom_state
  end
end