Contents

module LogjamAgent
  module Forwarders
    @@forwarders = {}

    extend self

    def add(f)
      @@forwarders["#{f.app}-#{f.env}"] = f
    end

    def get(app, env)
      @@forwarders["#{app}-#{env}"]
    end

    def reset
      @@forwarders.each_value {|f| f.reset}
    end

    # properly close open sockets on program termination
    at_exit { reset }

    def inspect
      super + ": #{@@forwarders.inspect}"
    end
  end
end

Version data entries

36 entries across 36 versions & 1 rubygems

Version	Path
logjam_agent-0.39.1	lib/logjam_agent/forwarders.rb
logjam_agent-0.39.0	lib/logjam_agent/forwarders.rb
logjam_agent-0.38.5	lib/logjam_agent/forwarders.rb
logjam_agent-0.38.4	lib/logjam_agent/forwarders.rb
logjam_agent-0.38.3	lib/logjam_agent/forwarders.rb
logjam_agent-0.38.2	lib/logjam_agent/forwarders.rb
logjam_agent-0.38.1	lib/logjam_agent/forwarders.rb
logjam_agent-0.38.0	lib/logjam_agent/forwarders.rb
logjam_agent-0.37.1	lib/logjam_agent/forwarders.rb
logjam_agent-0.37.0	lib/logjam_agent/forwarders.rb
logjam_agent-0.36.0	lib/logjam_agent/forwarders.rb
logjam_agent-0.35.1	lib/logjam_agent/forwarders.rb
logjam_agent-0.35.0	lib/logjam_agent/forwarders.rb
logjam_agent-0.34.3	lib/logjam_agent/forwarders.rb
logjam_agent-0.34.2	lib/logjam_agent/forwarders.rb
logjam_agent-0.34.1	lib/logjam_agent/forwarders.rb
logjam_agent-0.34.0	lib/logjam_agent/forwarders.rb
logjam_agent-0.33.3	lib/logjam_agent/forwarders.rb
logjam_agent-0.33.2	lib/logjam_agent/forwarders.rb
logjam_agent-0.33.1	lib/logjam_agent/forwarders.rb