Class: LogStash::Util::PluginDeadLetterQueueWriter

Inherits:
Object
  • Object
show all
Defined in:
lib/logstash/util/dead_letter_queue_manager.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(inner_writer, plugin_id, plugin_type) ⇒ PluginDeadLetterQueueWriter

Returns a new instance of PluginDeadLetterQueueWriter.



8
9
10
11
12
 
# File 'lib/logstash/util/dead_letter_queue_manager.rb', line 8

def initialize(inner_writer, plugin_id, plugin_type)
  @plugin_id = plugin_id
  @plugin_type = plugin_type
  @inner_writer = inner_writer
end

Instance Attribute Details

#inner_writer ⇒ Object (readonly)

Returns the value of attribute inner_writer.



6
7
8
 
# File 'lib/logstash/util/dead_letter_queue_manager.rb', line 6

def inner_writer
  @inner_writer
end

#plugin_id ⇒ Object (readonly)

Returns the value of attribute plugin_id.



6
7
8
 
# File 'lib/logstash/util/dead_letter_queue_manager.rb', line 6

def plugin_id
  @plugin_id
end

#plugin_type ⇒ Object (readonly)

Returns the value of attribute plugin_type.



6
7
8
 
# File 'lib/logstash/util/dead_letter_queue_manager.rb', line 6

def plugin_type
  @plugin_type
end

Instance Method Details

#close ⇒ Object 



20
21
22
23
24
 
# File 'lib/logstash/util/dead_letter_queue_manager.rb', line 20

def close
  if @inner_writer && @inner_writer.is_open
    @inner_writer.close
  end
end

#write(logstash_event, reason) ⇒ Object 



14
15
16
17
18
 
# File 'lib/logstash/util/dead_letter_queue_manager.rb', line 14

def write(logstash_event, reason)
  if @inner_writer && @inner_writer.is_open
    @inner_writer.writeEntry(logstash_event.to_java, @plugin_type, @plugin_id, reason)
  end
end