class MCollective::Connector::Rabbitmq::EventLogger
Public Instance Methods
on_connected(params=nil)
click to toggle source
# File lib/mcollective/connector/rabbitmq.rb 14 def on_connected(params=nil) 15 Log.info("Connected to #{stomp_url(params)}") 16 rescue 17 end
on_connectfail(params=nil)
click to toggle source
# File lib/mcollective/connector/rabbitmq.rb 24 def on_connectfail(params=nil) 25 Log.info("TCP Connection to #{stomp_url(params)} failed on attempt #{params[:cur_conattempts]}") 26 rescue 27 end
on_connecting(params=nil)
click to toggle source
# File lib/mcollective/connector/rabbitmq.rb 9 def on_connecting(params=nil) 10 Log.info("TCP Connection attempt %d to %s" % [params[:cur_conattempts], stomp_url(params)]) 11 rescue 12 end
on_disconnect(params=nil)
click to toggle source
# File lib/mcollective/connector/rabbitmq.rb 19 def on_disconnect(params=nil) 20 Log.info("Disconnected from #{stomp_url(params)}") 21 rescue 22 end
on_hbfire(params, srind, curt)
click to toggle source
Log
heart beat fires
# File lib/mcollective/connector/rabbitmq.rb 81 def on_hbfire(params, srind, curt) 82 case srind 83 when "receive_fire" 84 Log.debug("Received heartbeat from %s: %s, %s" % [stomp_url(params), srind, curt]) 85 when "send_fire" 86 Log.debug("Publishing heartbeat to %s: %s, %s" % [stomp_url(params), srind, curt]) 87 end 88 rescue Exception => e 89 end
on_hbread_fail(params, ticker_data)
click to toggle source
Stomp 1.1+ - heart beat read (receive) failed.
# File lib/mcollective/connector/rabbitmq.rb 49 def on_hbread_fail(params, ticker_data) 50 if ticker_data["lock_fail"] 51 if params[:max_hbrlck_fails] == 0 52 # failure is disabled 53 Log.debug("Heartbeat failed to acquire readlock for '%s': %s" % [stomp_url(params), ticker_data.inspect]) 54 elsif ticker_data['lock_fail_count'] >= params[:max_hbrlck_fails] 55 # we're about to force a disconnect 56 Log.error("Heartbeat failed to acquire readlock for '%s': %s" % [stomp_url(params), ticker_data.inspect]) 57 else 58 Log.warn("Heartbeat failed to acquire readlock for '%s': %s" % [stomp_url(params), ticker_data.inspect]) 59 end 60 else 61 if params[:max_hbread_fails] == 0 62 # failure is disabled 63 Log.debug("Heartbeat read failed from '%s': %s" % [stomp_url(params), ticker_data.inspect]) 64 elsif ticker_data['read_fail_count'] >= params[:max_hbread_fails] 65 # we're about to force a reconnect 66 Log.error("Heartbeat read failed from '%s': %s" % [stomp_url(params), ticker_data.inspect]) 67 else 68 Log.warn("Heartbeat read failed from '%s': %s" % [stomp_url(params), ticker_data.inspect]) 69 end 70 end 71 rescue Exception => e 72 end
on_hbwrite_fail(params, ticker_data)
click to toggle source
Stomp 1.1+ - heart beat send (transmit) failed.
# File lib/mcollective/connector/rabbitmq.rb 75 def on_hbwrite_fail(params, ticker_data) 76 Log.error("Heartbeat write failed from '%s': %s" % [stomp_url(params), ticker_data.inspect]) 77 rescue Exception => e 78 end
on_miscerr(params, errstr)
click to toggle source
# File lib/mcollective/connector/rabbitmq.rb 29 def on_miscerr(params, errstr) 30 Log.error("Unexpected error on connection #{stomp_url(params)}: #{errstr}") 31 rescue 32 end
on_ssl_connected(params)
click to toggle source
# File lib/mcollective/connector/rabbitmq.rb 39 def on_ssl_connected(params) 40 Log.info("SSL session established with #{stomp_url(params)}") 41 rescue 42 end
on_ssl_connectfail(params)
click to toggle source
# File lib/mcollective/connector/rabbitmq.rb 44 def on_ssl_connectfail(params) 45 Log.error("SSL session creation with #{stomp_url(params)} failed: #{params[:ssl_exception]}") 46 end
on_ssl_connecting(params)
click to toggle source
# File lib/mcollective/connector/rabbitmq.rb 34 def on_ssl_connecting(params) 35 Log.info("Establishing SSL session with #{stomp_url(params)}") 36 rescue 37 end
stomp_url(params)
click to toggle source
# File lib/mcollective/connector/rabbitmq.rb 91 def stomp_url(params) 92 "%s://%s@%s:%d" % [ params[:cur_ssl] ? "stomp+ssl" : "stomp", params[:cur_login], params[:cur_host], params[:cur_port]] 93 end