Sha256: f97f09c15299e3ff77085ed4fca8f0596d9787447a290e34ec574df033da7d47
Contents?: true
Size: 883 Bytes
Versions: 8
Compression:
Stored size: 883 Bytes
Contents
# frozen_string_literal: true
# :reek:TooManyStatements
module RubyRabbitmqJanus
module Rabbit
module Listener
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
#
# This publisher don't post message. Is listen just an standard queue to
# Janus. By default is "from-janus". It's a parameter in config to this
# gem.
class From < Base
private
def subscribe_queue
reply = @rabbit.queue(Tools::Config.instance.queue_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
8 entries across 8 versions & 1 rubygems