Contents

require "harness/active_publisher/version"

::ActiveSupport::Notifications.subscribe "wait_for_async_queue.active_publisher" do |*args|
  event = ::ActiveSupport::Notifications::Event.new(*args)
  ::Harness.timing "active_publisher.waiting_for_async_queue", event.duration
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
harness-active_publisher-0.1.0	lib/harness/active_publisher.rb