class Karafka::Instrumentation::Monitor

def subscribe(event_name_or_listener)

Parameters:
  • event_name_or_listener (String, Object) -- name of the event we want to subscribe to 
def subscribe(event_name_or_listener)
  return super unless event_name_or_listener.is_a?(String)
  return super if available_events.include?(event_name_or_listener)
  raise Errors::UnregisteredMonitorEvent, event_name_or_listener
end