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