Method: LogStash::Stomp::Handler#unbind

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

#unbind ⇒ Object 



32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/logstash/stomp/handler.rb', line 32

def unbind
  if $EVENTMACHINE_STOPPING
    @logger.debug(["Connection to stomp broker died (probably since we are exiting)",
                  { :url => @url }])
    return
  end
                
  @logger.error(["Connection to stomp broker died, retrying.", { :url => @url }])
  @ready = false
  EventMachine::Timer.new(1) do
    reconnect(@url.host, @url.port)
  end
end