class LogStash::Inputs::Stomp::InputHandler

Public Instance Methods

receive_msg(message) click to toggle source
Calls superclass method LogStash::Stomp::Handler#receive_msg
# 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