class ActiveSupport::SubscriberQueueRegistry

:nodoc:
for further details.
See the documentation of ActiveSupport::PerThreadRegistry
This is a registry for all the event stacks kept for subscribers.

def get_queue(queue_key) 

def get_queue(queue_key)
  @registry[queue_key] ||= []
end

def initialize 

def initialize
  @registry = {}
end