Class: LogStash::Inputs::Jms::LegacyHeadersMapper

Inherits:
HeadersMapper
  • Object
show all
Defined in:
lib/logstash/inputs/jms.rb

Overview

For plugin compatibility due the use of JMS gem’s Message#attributes.

Constant Summary collapse

INSTANCE = 
self.new

Instance Method Summary collapse

Instance Method Details

#call(msg) ⇒ Object 



530
531
532
533
534
535
 
# File 'lib/logstash/inputs/jms.rb', line 530

def call(msg)
  map = super(msg)
  delivery_mode = jms_delivery_mode(msg)
  map['jms_delivery_mode_sym'] = delivery_mode ? delivery_mode.to_sym : nil
  map
end