Added the ability to queue or "prime" subscribers with messages. Ran into a situation where a subscriber wasn't ready to process events yet but would need to process them once it was ready.