class ZuoraConnect::AppInstanceBase
def queue_start(current_user: 'Default')
def queue_start(current_user: 'Default') paused_user = Resque.redis.zrange("PauseQueue", 0, -1).map {|key| key.split("__")[0] == "#{self.id}" ? key.split("__")[1] : nil}.compact.first if paused_user == current_user || paused_user.blank? Resque.redis.zrem("PauseQueue", "#{self.id}__#{paused_user}") else raise "Can only unpause for user #{paused_user}." end end