Sha256: 88bafc5880237be0eb7dce949cbfa8cfdd0e2002965e9ad632ea779249be9646
Contents?: true
Size: 742 Bytes
Versions: 9
Compression:
Stored size: 742 Bytes
Contents
require 'alephant/logger'
require 'alephant/broker/component'
module Alephant
module Broker
module Request
class Batch
include Logger
attr_reader :batch_id, :components
def initialize(env)
logger.debug("Request::Batch#initialize(#{env.settings})")
@batch_id = env.data['batch_id']
@components = components_for env
logger.debug("Request::Batch#initialize: id: #{@batch_id}")
end
private
def components_for(env)
env.data['components'].map do |c|
Component.new(
c['component'],
batch_id,
c['options']
)
end
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems