Module: ExternalServices::Action::ClassMethods

Defined in:
app/models/concerns/external_services/action.rb

Instance Method Summary collapse

Instance Method Details

#clear_sidekiq_queues ⇒ Object 



37
38
39
40
41
42
43
 
# File 'app/models/concerns/external_services/action.rb', line 37

def clear_sidekiq_queues
  Sidekiq.redis do |conn|
    conn.keys.select { |k| k.include?(QUEUE_PREFIX) }.each do |k|
      conn.del k
    end
  end
end

#perform_unprocessed ⇒ Object 



45
46
47
48
49
 
# File 'app/models/concerns/external_services/action.rb', line 45

def perform_unprocessed
  Rails.logger.info "Running unprocessed #{self.class.name.demodulize} api actions..."

  unprocessed.each(&:kick_active_job)
end