Module: SongkickQueue::Consumer

Defined in:
lib/songkick_queue/consumer.rb

Defined Under Namespace

Modules: ClassMethods

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#delivery_info ⇒ Object (readonly)

Returns the value of attribute delivery_info.



3
4
5
 
# File 'lib/songkick_queue/consumer.rb', line 3

def delivery_info
  @delivery_info
end

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



3
4
5
 
# File 'lib/songkick_queue/consumer.rb', line 3

def logger
  @logger
end

Class Method Details

.included(base) ⇒ Object 



28
29
30
 
# File 'lib/songkick_queue/consumer.rb', line 28

def self.included(base)
  base.extend(ClassMethods)
end

Instance Method Details

#initialize(delivery_info, logger) ⇒ Object

Parameters:

  • to use for acknowledgement and requeues, rejects etc…

  • to expose to the client consumer for logging



35
36
37
38
 
# File 'lib/songkick_queue/consumer.rb', line 35

def initialize(delivery_info, logger)
  @delivery_info = delivery_info
  @logger        = logger
end

#process(message) ⇒ Object

Placeholder method to ensure each client consumer defines their own process message

Parameters:

  • to process

Raises:



45
46
47
48
 
# File 'lib/songkick_queue/consumer.rb', line 45

def process(message)
  fail NotImplementedError, 'you must define a #process method in your ' +
    'consumer class, see the README for more info.'
end