class ZuoraConnect::AppInstanceBase

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