Class: LogStash::Inputs::Stomp::InputHandler

Inherits:
Stomp::Handler
  • Object
show all
Defined in:
lib/logstash/inputs/stomp.rb

Instance Attribute Summary

Attributes inherited from Stomp::Handler

#ready, #should_subscribe

Instance Method Summary collapse

Methods inherited from Stomp::Handler

#connection_completed, #initialize, #unbind

Constructor Details

This class inherits a constructor from LogStash::Stomp::Handler

Instance Method Details

#receive_msg(message) ⇒ Object 



20
21
22
23
24
25
26
27
 
# File 'lib/logstash/inputs/stomp.rb', line 20

def receive_msg(message)
  super

  unless message.command == "CONNECTED"
    event = LogStash::Event.from_json(message.body)
    @input.receive(event)
  end
end