Contents

# frozen_string_literal: true

module RubyRabbitmqJanus
  module Rabbit
    module Publisher
      # @author VAILLANT Jeremy <[e-mail]>
      # This publisher send and read an message in queues
      class Publisher < BasePublisher
        # Intialize a publisher for sending and reading a message
        def initialize(exchange)
          super()
          @exchange = exchange.default_exchange
          @message = nil
          subscribe_to_queue
        end

        # Publish an message in queue
        def send_a_message(request)
          Tools::Log.instance.info "Send request type : #{request.type}"
          @message = request
          @exchange.publish(@message.to_json,
                            request.options.merge!(reply_to: queue_name))
          return_response
        end

        private

        # Subscribe to queue selectd with a message
        def subscribe_to_queue
          reply.subscribe do |_delivery_info, propertie, payload|
            if @message.correlation.eql?(propertie.correlation_id)
              @response = JSON.parse payload
              lock.synchronize { condition.signal }
            end
          end
        end

        # Name to queue used for this publisher
        # @return [String] Name to queue used
        def queue_name
          reply.name
        end

        attr_accessor :message
      end
    end
  end
end

require 'rrj/rabbit/publish/admin'
require 'rrj/rabbit/publish/exclusive'
require 'rrj/rabbit/publish/non_exclusive'

Version data entries

5 entries across 5 versions & 1 rubygems

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