module Services::RabbitWrapper::FromConfig
Public Class Methods
run(config: nil, sub_proc: nil)
click to toggle source
# File lib/services/rabbit_wrapper/from_config.rb, line 7 def self.run(config: nil, sub_proc: nil) rabbit_wrapper = Services::RabbitWrapper::Base.new(config: config) msg_counter = 0 rabbit_wrapper.subscribe do |body| msg_counter += 1 puts " Processing Msg Number #{msg_counter}" sub_proc.call(body, rabbit_wrapper) end rabbit_wrapper end