Contents

# frozen_string_literal: true

module RubyRabbitmqJanus
  module Rabbit
    module Publisher
      # @author VAILLANT Jeremy <[e-mail]>
      # Publish message in queue non exclusive. By default "to-janus".
      # This an option in config to this gem.
      class PublishNonExclusive < Publisher
        # Define an publisher for create non exclusive queue
        def initialize(exchange)
          @reply = exchange.queue(queue_from)
          super(exchange)
          Tools::Log.instance.debug 'Create/Connect to queue non exclusive'
        end

        private

        attr_reader :reply

        # Define queue used for posting a message to API public
        def queue_from
          Tools::Config.instance.options['queues']['queue_from']
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
ruby_rabbitmq_janus-1.0.6	lib/rrj/rabbit/publish/non_exclusive.rb
ruby_rabbitmq_janus-1.0.5	lib/rrj/rabbit/publish/non_exclusive.rb
ruby_rabbitmq_janus-1.0.4	lib/rrj/rabbit/publish/non_exclusive.rb
ruby_rabbitmq_janus-1.0.3	lib/rrj/rabbit/publish/non_exclusive.rb