Added a retry subscriber, made QueueSubscriber play nice with others.