Sha256: 097f4bad52d6b99fa5a0fa708c5832d8bfcb3e70f17d17599d0aa394bcc3e6ba
Contents?: true
Size: 808 Bytes
Versions: 10
Compression:
Stored size: 808 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.safe_load(
File.read(@env.rabbitmq_configuration_path), [], [], true
)
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems