class ZuoraConnect::AppInstanceBase

def queue_start(current_user: 'Default')
  paused_user = Redis.current.get("resque:PauseQueue:#{self.id}") 
  if paused_user == current_user || paused_user.blank?
    Redis.current.del("resque:PauseQueue:#{self.id}")
  else
    raise "Can only unpause for user #{paused_user}." 
  end
end