Sha256: acb5ca660add0a81b4edf2e8ec2e370578ae3873a17bf0073cccb1f69836a6e5
Contents?: true
Size: 567 Bytes
Versions: 5
Compression:
Stored size: 567 Bytes
Contents
# An application containing backend jobs servers
class MissionControl::Jobs::Application
include MissionControl::Jobs::IdentifiedByName
attr_reader :servers
def initialize(name:)
super
@servers = MissionControl::Jobs::IdentifiedElements.new
end
def add_servers(queue_adapters_by_name)
queue_adapters_by_name.each do |name, queue_adapter|
adapter, cleaner = queue_adapter
servers << MissionControl::Jobs::Server.new(name: name.to_s, queue_adapter: adapter,
backtrace_cleaner: cleaner, application: self)
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems