require_relative './common'

LOG.info('starting producer')

stopping = false

ending_proc = proc do
  stopping = true
end

trap 'TERM', &ending_proc
trap 'INT', &ending_proc

counter = 0

until stopping
  10.times do
    counter += 1
    begin
      MessageDriver::Client.publish(:basic_consumer_producer, "message #{counter}")
    rescue MessageDriver::ConnectionError => e
      LOG.info("The connection is closed! #{e}")
      sleep 1
      LOG.info('retrying...')
      retry
    end
  end
  LOG.info("sent 10 more messages for a total of #{counter}")
  sleep 1
end

LOG.info('stopping producer')
MessageDriver::Broker.stop