Sha256: 2e4ec6bc7a96342ff999a15ad0a4e8c1748953f02e8263b4b4943db7faf35859
Contents?: true
Size: 629 Bytes
Versions: 8
Compression:
Stored size: 629 Bytes
Contents
require 'honeybadger/plugin'
module Honeybadger
module Plugins
Plugin.register :karafka do
requirement { defined?(::Karafka) && ::Karafka.respond_to?(:monitor) }
execution do
require 'honeybadger/karafka'
errors_listener = ::Honeybadger::Karafka::ErrorsListener.new
::Karafka.monitor.subscribe(errors_listener)
::Karafka.producer.monitor.subscribe(errors_listener) if ::Karafka.respond_to?(:producer)
if config.load_plugin_insights?(:karafka)
::Karafka.monitor.subscribe(::Honeybadger::Karafka::InsightsListener.new)
end
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems