Sha256: b6572e0005a3a8b11506a27eb2f5bdf1f37e725d6ef696f378214c86120718cc
Contents?: true
Size: 760 Bytes
Versions: 10
Compression:
Stored size: 760 Bytes
Contents
# frozen_string_literal: true
module Orchestration
module Services
module RabbitMQ
class Configuration
include ConfigurationBase
self.service_name = 'rabbitmq'
def initialize(env, service_name = nil)
super
@settings = nil
return unless defined?(RabbitMQ)
return unless File.exist?(@env.rabbitmq_configuration_path)
@settings = config.fetch(@env.environment)
@settings.merge!('port' => PORT) unless @settings.key?('port')
end
def friendly_config
"[bunny] amqp://#{host}:#{local_port}"
end
private
def config
yaml(File.read(@env.rabbitmq_configuration_path))
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems