sul-dlss/pre-assembly

# frozen_string_literal: true

namespace :rabbitmq do
  desc 'Setup routing'
  task setup: :environment do
    require 'bunny'

    conn = Bunny.new(hostname: Settings.rabbitmq.hostname,
                     vhost: Settings.rabbitmq.vhost,
                     username: Settings.rabbitmq.username,
                     password: Settings.rabbitmq.password).tap(&:start)

    channel = conn.create_channel

    # connect topic to the queue
    exchange = channel.topic('sdr.workflow')
    queue = channel.queue('preassembly.accession_complete', durable: true)
    queue.bind(exchange, routing_key: 'end-accession.completed')
    queue.bind(exchange, routing_key: '*.error')

    conn.close
  end
end