Sha256: c89c4d8afd66f15b3eac101b2457393dd8eff8cea473b04e78a39a8ece98f15e
Contents?: true
Size: 1.3 KB
Versions: 16
Compression:
Stored size: 1.3 KB
Contents
# encoding: utf-8
# This file is distributed under New Relic's license terms.
# See https://github.com/newrelic/rpm/blob/master/LICENSE for complete details.
module NewRelic::Agent
# Basic mechanism for the agent instance to provide agent-wide eventing.
# It is intended to keep different pieces of the app decoupled from each other.
#
# While an EventListener could be used elsewhere, it's strongly expected
# your eventing needs should be met by the agent's instance.
class EventListener
attr_accessor :runaway_threshold
def initialize
@events = {}
@runaway_threshold = 100
end
def subscribe(event, &handler)
@events[event] ||= []
@events[event] << handler
check_for_runaway_subscriptions(event)
end
def check_for_runaway_subscriptions(event)
count = @events[event].size
NewRelic::Agent.logger.debug("Run-away event subscription on #{event}? Subscribed #{count}") if count > @runaway_threshold
end
def clear
@events.clear
end
def notify(event, *args)
return unless @events.has_key?(event)
@events[event].each do |handler|
begin
handler.call(*args)
rescue => err
NewRelic::Agent.logger.debug("Failure during notify for #{@event}", err)
end
end
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems