Do the inital recovery dispatch in the iterate() thread so that the addSubscription() operation on the Queue executes quickly.