Method: LogStash::Stomp::Handler#receive_msg

Defined in:
lib/logstash/stomp/handler.rb

#receive_msg(message) ⇒ Object 



47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/logstash/stomp/handler.rb', line 47

def receive_msg(message)
  @logger.debug(["receiving message", { :msg => message }])
  if message.command == "CONNECTED"
    if @should_subscribe
      @logger.debug(["subscribing to", { :path => @url.path }])
      subscribe @url.path
      return
    end
    @ready = true
  end
end