Add concurrency protection to SubscriptionManager class.