Sha256: 340912af35ac128061d835ba206381114e7e6429b37dec38e940b5257991c78b
Contents?: true
Size: 675 Bytes
Versions: 15
Compression:
Stored size: 675 Bytes
Contents
# frozen_string_literal: true
module RubyRabbitmqJanus
module Rabbit
module Publisher
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
class PublishExclusive < Publisher
# Initialize an queue exclusive and generated automaticaly by bunny
def initialize(exchange, name_queue)
@reply = exchange.queue(name_queue, exclusive: true)
super(exchange)
subscribe_to_queue
end
# Send an message to queue and waiting a response
def send_a_message(request)
super(request)
return_response
end
private
attr_reader :reply
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems