Created a registry for ActiveSupport::Subscriber queues

I'm limiting the number of thread locals that come from each new subscriber. Instead of creating a new thread local for each queue, there is only a single thread local that is created which stores all the queues.

It follows the pattern of the ``ActiveSupport::PerThreadRegistry`` module.