Sha256: 84bf487d1d50c22950db78e13025ae5f02a76854a505f738131a4a7d785155d4

Contents?: true

Size: 608 Bytes

Versions: 27

Compression:

Stored size: 608 Bytes

Contents

# frozen_string_literal: true

module RubyRabbitmqJanus
  module Rabbit
    module Listener
      # @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
      #
      # This publisher don't post message. Is listen just an admin queue to
      # Janus. By default is "from-janus-admin". It's a parameter in config
      # to this gem.
      class FromAdmin < From
        private

        def reply
          rabbit.queue(Tools::Config.instance.queue_admin_from)
        end

        def response_class(payload)
          Janus::Responses::Admin.new(JSON.parse(payload))
        end
      end
    end
  end
end

Version data entries

27 entries across 27 versions & 1 rubygems

Version Path
ruby_rabbitmq_janus-4.0.1 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.1.pre.1265973744 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.1.pre.1265506307 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.1.pre.1265140558 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.1001345090 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.1001181479 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.1001132533 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.1001107243 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.1001043172 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.949167646 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.946892338 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.946565704 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.939149205 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.939137013 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.939133437 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.939119110 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.939113634 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-4.0.0.pre.850041590 lib/rrj/rabbit/listener/from_admin.rb
ruby_rabbitmq_janus-3.0.1 lib/rrj/rabbit/listener/from_admin.rb