Method: LogStash::MultiQueue#remove_queue

Defined in:
lib/logstash/multiqueue.rb

#remove_queue(queue) ⇒ Object 



43
44
45
46
47
 
# File 'lib/logstash/multiqueue.rb', line 43

def remove_queue(queue)
  @mutex.synchronize do
    @queues.delete(queue)
  end
end