Sha256: 293353ce5118ad2939c82b333dc274f4211a08d7f343efb2bab59bf1beaa6c0d
Contents?: true
Size: 1.11 KB
Versions: 18
Compression:
Stored size: 1.11 KB
Contents
# frozen_string_literal: true
module RubyRabbitmqJanus
module Rabbit
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
# Manage properties to message sending in rabbitmq queue
class Propertie
attr_reader :correlation
# Initialize a message sending to rabbitmq
def initialize
Tools::Log.instance.debug 'initalize a propertie to message'
@correlation = SecureRandom.uuid
end
# Define options sending to rabbitmq
def options
Tools::Log.instance.debug 'Add options to propertie to message'
{
routing_key: Tools::Config.instance.options['queues']['queue_to'],
correlation_id: @correlation,
content_type: 'application/json'
}
end
# Define option sending to rabbitmq for janus admin message
def options_admin
Tools::Log.instance.debug 'Add options to propertie to message'
{
routing_key: Tools::Config.instance.options['queues']['admin']['queue_to'],
correlation_id: @correlation,
content_type: 'application/json'
}
end
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems