Sha256: 8f288bcc4a25d45c81de0c4c31114668da78bf44649c28add1c0c5f605820661
Contents?: true
Size: 935 Bytes
Versions: 44
Compression:
Stored size: 935 Bytes
Contents
# frozen_string_literal: true
module RubyRabbitmqJanus
module Rabbit
module Publisher
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
#
# 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(Tools::Config.instance.queue_from)
super(exchange)
rescue
raise Errors::Rabbit::PublishNonExclusive::Initialize
end
# Send an message to queue
#
# @param [String] request JSON request sending to rabbitmq queue
def publish(request)
super(request)
rescue
raise Errors::Rabbit::PublishNonExclusive::Publish
end
private
attr_reader :reply
end
end
end
end
Version data entries
44 entries across 44 versions & 1 rubygems