Class: SmartQue::Consumer

Inherits:
Consumers::Base show all
Defined in:
lib/smart_que/consumer.rb

Constant Summary

Constants inherited from Consumers::Base

Consumers::Base::QUEUE_NAME

Instance Attribute Summary

Attributes inherited from Consumers::Base

#queue_name

Instance Method Summary collapse

Methods inherited from Consumers::Base

#channel, #config, #connection, #queue, #start, #wait_for_threads

Constructor Details

#initialize(queue_name = nil) ⇒ Consumer

Initialize



7
8
9
 
# File 'lib/smart_que/consumer.rb', line 7

def initialize(queue_name = nil)
  @queue_name = ( queue_name || self.class::QUEUE_NAME )
end

Instance Method Details

#run(payload) ⇒ Object

Consume message and perform tasks



14
15
16
17
18
 
# 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