Class: LogStash::Util::DeadLetterQueueFactory
- Inherits:
-
Object
- Object
- LogStash::Util::DeadLetterQueueFactory
- Defined in:
- lib/logstash/util/dead_letter_queue_manager.rb
Class Method Summary collapse
Class Method Details
.close(pipeline_id) ⇒ Object
57 58 59 |
# File 'lib/logstash/util/dead_letter_queue_manager.rb', line 57 def self.close(pipeline_id) DeadLetterQueueFactory.close(pipeline_id) end |
.get(pipeline_id) ⇒ Object
48 49 50 51 52 53 54 55 |
# File 'lib/logstash/util/dead_letter_queue_manager.rb', line 48 def self.get(pipeline_id) if LogStash::SETTINGS.get("dead_letter_queue.enable") return DeadLetterQueueWriter.new( DeadLetterQueueFactory.getWriter(pipeline_id, LogStash::SETTINGS.get("path.dead_letter_queue"), LogStash::SETTINGS.get('dead_letter_queue.max_bytes'))) else return DeadLetterQueueWriter.new(nil) end end |