Sha256: bd20e13e2dff1bdd7172ab540a1aa8baa88e87a4258b8940735dc865c167fddb
Contents?: true
Size: 473 Bytes
Versions: 7
Compression:
Stored size: 473 Bytes
Contents
require_relative "consumers/base"
module SmartQue
class Consumer < Consumers::Base
# Initialize
def initialize(queue_name = nil)
@queue_name = ( queue_name || self.class::QUEUE_NAME )
end
# Instance methods
# Consume message and perform tasks
def run(payload)
# Implement logic in the corresponding consumer
Rails.logger.info "Not Implemented, Please define run method for the consumer class."
:ok
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems