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

Inherits:

Stomp::Handler

• Object
• EventMachine::Connection
• Stomp::Handler
• LogStash::Inputs::Stomp::InputHandler

Defined in:

lib/logstash/inputs/stomp.rb

Instance Attribute Summary

Attributes inherited from Stomp::Handler

#ready, #should_subscribe

Instance Method Summary

• #receive_msg(message) ⇒ Object

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

# 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