Sha256: c4dfdc1b2ba8fab67f7988efb98ac8f0b932d1f98bd21771af929c469ac20a23
Contents?: true
Size: 698 Bytes
Versions: 9
Compression:
Stored size: 698 Bytes
Contents
# frozen_string_literal: true
# :reek:InstanceVariableAssumption
module RubyRabbitmqJanus
module Rabbit
module Listener
# Listener to admin queue
class FromAdmin < From
private
def subscribe_queue
reply = @rabbit.queue(Tools::Config.instance.queue_admin_from)
@rabbit.prefetch(1)
reply.bind(binding).subscribe(opts_subs) do |info, prop, payload|
info_subscribe(info, prop, payload)
synchronize_response(info, payload)
end
rescue => exception
raise RubyRabbitmqJanus::Errors::Rabbit::Listener::From::ListenEvents,
exception
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems