Class for Stomp 1.1.9 callback based logging
# File lib/mcollective/connector/activemq.rb, line 118 def on_connected(params=nil) Log.info("Connected to #{stomp_url(params)}") rescue end
# File lib/mcollective/connector/activemq.rb, line 128 def on_connectfail(params=nil) Log.info("TCP Connection to #{stomp_url(params)} failed on attempt #{params[:cur_conattempts]}") rescue end
# File lib/mcollective/connector/activemq.rb, line 113 def on_connecting(params=nil) Log.info("TCP Connection attempt %d to %s" % [params[:cur_conattempts], stomp_url(params)]) rescue end
# File lib/mcollective/connector/activemq.rb, line 123 def on_disconnect(params=nil) Log.info("Disconnected from #{stomp_url(params)}") rescue end
Log heart beat fires
# File lib/mcollective/connector/activemq.rb, line 185 def on_hbfire(params, srind, curt) case srind when "receive_fire" Log.debug("Received heartbeat from %s: %s, %s" % [stomp_url(params), srind, curt]) when "send_fire" Log.debug("Publishing heartbeat to %s: %s, %s" % [stomp_url(params), srind, curt]) end rescue Exception => e end
Stomp 1.1+ - heart beat read (receive) failed.
# File lib/mcollective/connector/activemq.rb, line 153 def on_hbread_fail(params, ticker_data) if ticker_data["lock_fail"] if params[:max_hbrlck_fails] == 0 # failure is disabled Log.debug("Heartbeat failed to acquire readlock for '%s': %s" % [stomp_url(params), ticker_data.inspect]) elsif ticker_data['lock_fail_count'] >= params[:max_hbrlck_fails] # we're about to force a disconnect Log.error("Heartbeat failed to acquire readlock for '%s': %s" % [stomp_url(params), ticker_data.inspect]) else Log.warn("Heartbeat failed to acquire readlock for '%s': %s" % [stomp_url(params), ticker_data.inspect]) end else if params[:max_hbread_fails] == 0 # failure is disabled Log.debug("Heartbeat read failed from '%s': %s" % [stomp_url(params), ticker_data.inspect]) elsif ticker_data['read_fail_count'] >= params[:max_hbread_fails] # we're about to force a reconnect Log.error("Heartbeat read failed from '%s': %s" % [stomp_url(params), ticker_data.inspect]) else Log.warn("Heartbeat read failed from '%s': %s" % [stomp_url(params), ticker_data.inspect]) end end rescue Exception => e end
Stomp 1.1+ - heart beat send (transmit) failed.
# File lib/mcollective/connector/activemq.rb, line 179 def on_hbwrite_fail(params, ticker_data) Log.error("Heartbeat write failed from '%s': %s" % [stomp_url(params), ticker_data.inspect]) rescue Exception => e end
# File lib/mcollective/connector/activemq.rb, line 133 def on_miscerr(params, errstr) Log.error("Unexpected error on connection #{stomp_url(params)}: #{errstr}") rescue end
# File lib/mcollective/connector/activemq.rb, line 143 def on_ssl_connected(params) Log.info("SSL session established with #{stomp_url(params)}") rescue end
# File lib/mcollective/connector/activemq.rb, line 148 def on_ssl_connectfail(params) Log.error("SSL session creation with #{stomp_url(params)} failed: #{params[:ssl_exception]}") end
# File lib/mcollective/connector/activemq.rb, line 138 def on_ssl_connecting(params) Log.info("Establishing SSL session with #{stomp_url(params)}") rescue end
# File lib/mcollective/connector/activemq.rb, line 195 def stomp_url(params) "%s://%s@%s:%d" % [ params[:cur_ssl] ? "stomp+ssl" : "stomp", params[:cur_login], params[:cur_host], params[:cur_port]] end