require 'vx/common/amqp'
require 'vx/message'

module Vx
  class Router
    class BuildsConsumer

      include Vx::Common::AMQP::Consumer
      include Helper::Logger

      exchange 'vx.builds'
      queue    'vx.worker.builds'
      ack      true

      model Message::PerformBuild

      def perform(message)
        logger.tagged self.class.consumer_id do
          build = Build.new message
          Router.new(build).perform
        end
        ack!
      end

    end
  end
end