class SmartQue::Consumer

Public Class Methods

new(queue_name = nil) click to toggle source

Initialize

# File lib/smart_que/consumer.rb, line 7
def initialize(queue_name = nil)
  @queue_name = ( queue_name || self.class::QUEUE_NAME )
end

Public Instance Methods

run(payload) click to toggle source

Consume message and perform tasks

# File lib/smart_que/consumer.rb, line 14
def run(payload)
  # Implement logic in the corresponding consumer
  Rails.logger.info "Not Implemented, Please define run method for the consumer class."
  :ok
end