require 'mq'

  describe 'AMQP' do
    it('sends data to queue') do
      EM.run do
        AMQP.start(logging: false) do
          q = MQ.new.queue("test_sink")
          q.subscribe do |hdr, data|
            p hdr, data
            EM.next_tick {
              q.unsubscribe; q.delete
              AMQP.stop { EM.stop }
            }
          end
        end
        EM.add_timer(0.2) do
          MQ.queue('test_sink').publish 'data'
        end
      end
    end

    it('sends data to queue') do
      EM.run do
        AMQP.start(logging: false) do
          q = MQ.new.queue("test_sink")
          q.subscribe do |hdr, data|
            p hdr, data
            EM.next_tick {
              q.unsubscribe; q.delete
              AMQP.stop { EM.stop }
            }
          end
        end
        EM.add_timer(0.2) do
          MQ.queue('test_sink').publish 'data'
        end
      end
    end

  end