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