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