lib/rocket_job/event.rb in rocketjob-5.3.0 vs lib/rocket_job/event.rb in rocketjob-5.3.1

- old
+ new

@@ -102,11 +102,9 @@ else collection.client[collection_name, {capped: true, size: size}].create end end - private - @load_time = Time.now.utc @subscribers = Concurrent::Map.new { Concurrent::Array.new } def self.add_subscriber(subscriber) name = subscriber.class.event_name