Initial pass at idempotent subscriptions